Method: Wukong::Processor#process

Defined in:
lib/wukong/processor.rb

#process(record) {|record| ... } ⇒ Object

This method is called once per record.

Override this method in your subclass.

Parameters:

  • record (Object)

Yields:

  • record the record you want to yield

Yield Parameters:

  • record (Object) —

    the yielded record



83
84
85
 
# File 'lib/wukong/processor.rb', line 83

def process(record, &emit)
  yield record
end