Class: Wukong::Streamer::RecordStreamer

Inherits:
Base show all
Defined in:
lib/wukong/streamer/record_streamer.rb

Direct Known Subclasses

HadoopBinning::Mapper, InstanceStreamer

Instance Attribute Summary

Attributes inherited from Base

#own_options

Instance Method Summary (collapse)

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

- (Object) recordize(line)

Default recordizer: returns array of fields by splitting at tabs



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

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