Index

A

append() (brewery.ds.DataTarget method), [1] (brewery.ds.FieldList method) (brewery.ds.StreamAuditor method), [1] (brewery.metadata.FieldList method)

B

brewery.dq (module)

brewery.ds (module)

C

closed() (brewery.streams.Pipe method), [1] configure() (brewery.nodes.Node method) (brewery.streams.Node method) (brewery.streams.Stream method), [1] copy() (brewery.ds.FieldList method) (brewery.metadata.FieldList method)

CSVDataSource (class in brewery.ds), [1] CSVDataTarget (class in brewery.ds)

D

DataSource (class in brewery.ds), [1] DataStream (class in brewery.ds), [1] DataTarget (class in brewery.ds), [1] dict() (brewery.dq.FieldStatistics method), [1]

DistinctProbe (class in brewery.probes) done_receiving() (brewery.streams.Pipe method), [1] done_sending() (brewery.streams.Pipe method), [1] ds (module)

E

ESDataSource (class in brewery.ds)

F

Field (class in brewery.ds) (class in brewery.metadata) field() (brewery.ds.FieldList method) (brewery.metadata.FieldList method) field_selectors() (brewery.metadata.FieldMap method) field_statistics (brewery.ds.StreamAuditor attribute), [1] FieldError (class in brewery.streams) FieldList (class in brewery.ds) (class in brewery.metadata) FieldMap (class in brewery.metadata)

fields() (brewery.ds.FieldList method) (brewery.metadata.FieldList method) FieldStatistics (class in brewery.dq), [1] FieldTypeProbe (class in brewery.dq), [1] filter() (brewery.metadata.RowFieldFilter method) finalize() (brewery.dq.FieldStatistics method), [1] (brewery.ds.DataStream method), [1] (brewery.ds.SQLDataTarget method), [1] (brewery.nodes.Node method) (brewery.streams.Node method) fork() (brewery.streams.Stream method), [1]

G

GoogleSpreadsheetDataSource (class in brewery.ds), [1]

I

identifier() (brewery.nodes.Node class method) (brewery.streams.Node class method) index() (brewery.ds.FieldList method) (brewery.metadata.FieldList method) indexes() (brewery.ds.FieldList method) (brewery.metadata.FieldList method)

initialize() (brewery.ds.CSVDataSource method), [1] (brewery.ds.DataStream method), [1] (brewery.ds.ESDataSource method) (brewery.ds.GoogleSpreadsheetDataSource method), [1] (brewery.ds.MongoDBDataSource method), [1] (brewery.ds.MongoDBDataTarget method) (brewery.ds.SQLDataSource method), [1] (brewery.ds.SQLDataTarget method), [1] (brewery.ds.XLSDataSource method), [1] (brewery.nodes.Node method) (brewery.streams.Node method) input (brewery.nodes.Node attribute) (brewery.streams.Node attribute) input_fields (brewery.nodes.Node attribute) (brewery.streams.Node attribute)

M

map() (brewery.metadata.FieldMap method) metadata (module) MissingValuesProbe (class in brewery.probes)

MongoDBDataSource (class in brewery.ds), [1] MongoDBDataTarget (class in brewery.ds)

N

names() (brewery.ds.FieldList method) (brewery.metadata.FieldList method)

Node (class in brewery.nodes) (class in brewery.streams)

O

output_field_names (brewery.nodes.Node attribute) (brewery.streams.Node attribute)

output_fields (brewery.nodes.Node attribute) (brewery.streams.Node attribute)

P

Pipe (class in brewery.streams), [1] print_exception() (brewery.streams.StreamRuntimeError method), [1] probe() (brewery.dq.FieldStatistics method), [1] (brewery.probes.MissingValuesProbe method)

probes (module) put() (brewery.nodes.Node method) (brewery.streams.Node method) (brewery.streams.Pipe method), [1] put_record() (brewery.nodes.Node method) (brewery.streams.Node method)

R

read_fields() (brewery.ds.DataSource method), [1] records() (brewery.ds.DataSource method), [1] reset_type() (brewery.nodes.Node method) (brewery.streams.Node method) retype() (brewery.ds.FieldList method) (brewery.metadata.FieldList method) (brewery.nodes.Node method) (brewery.streams.Node method)

row_filter() (brewery.metadata.FieldMap method) RowFieldFilter (class in brewery.metadata) rows() (brewery.ds.DataSource method), [1] (brewery.streams.Pipe method), [1] run() (brewery.nodes.Node method) (brewery.streams.Node method) (brewery.streams.Stream method), [1]

S

selectors() (brewery.ds.FieldList method) (brewery.metadata.FieldList method) SimpleHTMLDataTarget (class in brewery.ds) SourceNode (class in brewery.nodes) SQLDataSource (class in brewery.ds), [1] SQLDataTarget (class in brewery.ds), [1] StatisticsProbe (class in brewery.probes)

StorageTypeProbe (class in brewery.probes) Stream (class in brewery.streams), [1] StreamAuditor (class in brewery.ds), [1] StreamRuntimeError (class in brewery.streams), [1] streams (module)

T

TargetNode (class in brewery.nodes)

to_dict() (brewery.ds.Field method) (brewery.metadata.Field method)

U

unique_storage_type (brewery.dq.FieldTypeProbe attribute), [1] (brewery.probes.StorageTypeProbe attribute)

update() (brewery.streams.Stream method), [1]

X

XLSDataSource (class in brewery.ds), [1]

Y

YamlDirectoryDataSource (class in brewery.ds), [1]

YamlDirectoryDataTarget (class in brewery.ds), [1]