Module: Chicago::Flow

Defined in:

lib/chicago/flow/sink.rb,
lib/chicago/flow/filter.rb,
lib/chicago/flow/array_sink.rb,
lib/chicago/flow/array_source.rb,
lib/chicago/flow/dataset_source.rb,
lib/chicago/flow/pipeline_stage.rb,
lib/chicago/flow/transformation.rb,
lib/chicago/flow/mysql_file_sink.rb,
lib/chicago/flow/pipeline_endpoint.rb,
lib/chicago/flow/transformation_chain.rb,
lib/chicago/flow/mysql_file_serializer.rb

Defined Under Namespace

Classes: ArraySink, ArraySource, DatasetSource, Error, Filter, MysqlFileSerializer, MysqlFileSink, PipelineEndpoint, PipelineStage, RaisingErrorHandler, Sink, Transformation, TransformationChain

Constant Summary

STREAM =

:_stream