Method: Wukong::DriverMethods#process

Defined in:
lib/wukong/driver.rb

#process(output_record) ⇒ Object

Classes including DriverMethods should override this method with some way of handling the output_record that is appropriate for the driver.

Parameters:

  • output_record (Object)

Raises:

  • (NotImplementedError) 


64
65
66
 
# File 'lib/wukong/driver.rb', line 64

def process output_record
  raise NotImplementedError.new("Define the #{self.class}#process method to handle output records from the dataflow")
end