Class: Wukong::Streamer::LineStreamer

Inherits:

Base

• Object
• Base
• Wukong::Streamer::LineStreamer

Defined in:

lib/wukong/streamer/line_streamer.rb

Instance Attribute Summary

Attributes inherited from Base

#own_options

Instance Method Summary

• #recordize(line) ⇒ Object

  Turns a flat line into a record for #process to consume.

Methods inherited from Base

#after_stream, #bad_record!, #before_stream, #each_record, #emit, #initialize, mapper, #mapper, #monitor, #options, #process, run, #run, #stream, #track

Constructor Details

This class inherits a constructor from Wukong::Streamer::Base

Instance Method Details

#recordize(line) ⇒ Object

Turns a flat line into a record for #process to consume

# File 'lib/wukong/streamer/line_streamer.rb', line 7

def recordize line
  [line]
end