Sha256: d8ebb540250b2cc0b08d820d7fb2b81b792fc3948e6d50977725ab857ed8e43d
Contents?: true
Size: 917 Bytes
Versions: 1
Compression:
Stored size: 917 Bytes
Contents
require 'multi_json' require 'configliere' require 'gorillib/logger/log' require 'gorillib/some' require 'gorillib/builder' require 'gorillib/model/serialization' require 'wukong/settings' require 'hanuman' # # Dataflow specific # require 'wukong/universe' require 'wukong/dataflow' require 'wukong/event' require 'wukong/processor' # processes records in series require 'wukong/widget/filter' # passes through only records that meet `accept?` require 'wukong/widget/source' # generates raw records from outside require 'wukong/widget/sink' # dispatch raw records to outside require 'wukong/widget/stringifier' # converts raw blobs into structured records and vice/versa require 'wukong/mapred' # the standard stream-sort-group-stream map/reduce flow require 'wukong/local_runner' require 'wukong/bad_record' # # Workflow Specific # require 'wukong/workflow/command'
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
wukong-3.0.0.pre | lib/wukong.rb |