Class: Wukong::Streamer::RecordStreamer

Inherits:

Base

• Object
• Base
• Wukong::Streamer::RecordStreamer

Defined in:

lib/wukong/streamer/record_streamer.rb

Instance Attribute Summary

Attributes inherited from Base

#own_options

Instance Method Summary

• #recordize(line) ⇒ Object

  Default recordizer: returns array of fields by splitting at tabs.

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

Default recordizer: returns array of fields by splitting at tabs

# File 'lib/wukong/streamer/record_streamer.rb', line 8

def recordize line
  line.split("\t") rescue nil
end