Module: Wukong::Streamer
- Defined in:
- lib/wukong/streamer.rb,
lib/wukong/streamer/base.rb,
lib/wukong/streamer/filter.rb,
lib/wukong/streamer/reducer.rb,
lib/wukong/streamer/set_reducer.rb,
lib/wukong/streamer/list_reducer.rb,
lib/wukong/streamer/line_streamer.rb,
lib/wukong/streamer/json_streamer.rb,
lib/wukong/streamer/record_streamer.rb,
lib/wukong/streamer/struct_streamer.rb,
lib/wukong/streamer/summing_reducer.rb,
lib/wukong/streamer/counting_reducer.rb,
lib/wukong/streamer/instance_streamer.rb,
lib/wukong/streamer/rank_and_bin_reducer.rb,
lib/wukong/streamer/accumulating_reducer.rb,
lib/wukong/streamer/uniq_by_last_reducer.rb
Defined Under Namespace
Modules: Filter, StructRecordizer Classes: AccumulatingReducer, Base, CountingReducer, IdentityMapper, IdentityReducer, InstanceStreamer, JsonStreamer, LineStreamer, ListReducer, RankAndBinReducer, RecordStreamer, Reducer, SetReducer, Streamer, StructStreamer, SummingReducer, UniqByLastReducer
