Contents

Wukong.processor(:simple) do  
  def process(record)
    yield record
  end
end

Wukong.processor(:skipped) do  
  def process(record)
    # skip records
  end
end

Wukong.processor(:multi) do  
  def process(record)
    3.times{ yield record }
  end
end

Wukong.processor(:test_example) do  
  def process(record)
    yield "I raised the #{record['foo']}"
  end
end

Wukong.dataflow(:flow) do
  from_json | test_example
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
wukong-storm-0.2.0	spec/support/examples.rb
wukong-storm-0.1.1	spec/support/examples.rb
wukong-storm-0.1.0	spec/support/examples.rb
wukong-storm-0.0.2	spec/support/examples.rb
wukong-storm-0.0.1	spec/support/examples.rb