Index

A

add() (brewery.pipes.Stream method)

append() (brewery.ds.DataTarget method) (brewery.ds.FieldList method) (brewery.ds.StreamAuditor method)

B

brewery.dq (module)

brewery.ds (module)

C

connect() (brewery.pipes.Stream method) copy() (brewery.ds.FieldList method)

CSVDataSource (class in brewery.ds)

D

DataSource (class in brewery.ds) DataStream (class in brewery.ds)

DataTarget (class in brewery.ds) dict() (brewery.dq.FieldStatistics method)

F

Field (class in brewery.ds) field() (brewery.ds.FieldList method) field_names (brewery.ds.DataStream attribute) field_statistics (brewery.ds.StreamAuditor attribute) FieldList (class in brewery.ds) fieldlist() (in module brewery.ds)

fields (brewery.ds.DataStream attribute) fields() (brewery.ds.FieldList method) FieldStatistics (class in brewery.dq) FieldTypeProbe (class in brewery.dq) finalize() (brewery.dq.FieldStatistics method) (brewery.ds.DataStream method) (brewery.pipes.Node method) flush() (brewery.pipes.Pipe method)

G

GoogleSpreadsheetDataSource (class in brewery.ds)

I

index() (brewery.ds.FieldList method) indexes() (brewery.ds.FieldList method) initialize() (brewery.ds.CSVDataSource method) (brewery.ds.DataStream method) (brewery.ds.GoogleSpreadsheetDataSource method) (brewery.ds.MongoDBDataSource method) (brewery.ds.SQLDataSource method) (brewery.ds.SQLDataTarget method) (brewery.ds.XLSDataSource method) (brewery.pipes.Node method) (brewery.pipes.Stream method)

input (brewery.pipes.Node attribute) input_fields (brewery.pipes.Node attribute)

M

MongoDBDataSource (class in brewery.ds)

N

names() (brewery.ds.FieldList method) Node (class in brewery.pipes) node() (brewery.pipes.Stream method)

node_sources() (brewery.pipes.Stream method) node_targets() (brewery.pipes.Stream method)

O

output_field_names (brewery.pipes.Node attribute)

output_fields (brewery.pipes.Node attribute)

P

Pipe (class in brewery.pipes) probe() (brewery.dq.FieldStatistics method)

put() (brewery.pipes.Node method) (brewery.pipes.Pipe method) put_record() (brewery.pipes.Node method)

R

read_fields() (brewery.ds.DataSource method) records() (brewery.ds.DataSource method) (brewery.pipes.Pipe method) remove() (brewery.pipes.Stream method)

remove_connection() (brewery.pipes.Stream method) rows() (brewery.ds.DataSource method) (brewery.pipes.Pipe method) run() (brewery.pipes.Node method) (brewery.pipes.Stream method)

S

sorted_nodes() (brewery.pipes.Stream method) SourceNode (class in brewery.pipes) SQLDataSource (class in brewery.ds) SQLDataTarget (class in brewery.ds)

stop() (brewery.pipes.Pipe method) Stream (class in brewery.pipes) StreamAuditor (class in brewery.ds)

T

TargetNode (class in brewery.pipes)

U

unique_storage_type (brewery.dq.FieldTypeProbe attribute)

X

XLSDataSource (class in brewery.ds)

Y

YamlDirectoryDataSource (class in brewery.ds)

YamlDirectoryDataTarget (class in brewery.ds)