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