Class: Wukong::Processor::FromTsv

Inherits:
Serializer show all
Defined in:
lib/wukong/widget/serializers.rb

Overview

A widget for deserializing inputs from TSV.

Examples:

Deserializing from TSV at the beginning of a data flow


Wukong.dataflow(:consumes_tsv) do
  from_tsv | ...
end

See Also:

Constant Summary

Constants inherited from Wukong::Processor

SerializerError

Instance Attribute Summary

Attributes included from Hanuman::StageInstanceMethods

#graph

Instance Method Summary collapse

Methods inherited from Serializer

#handle_error

Methods inherited from Wukong::Processor

configure, description, #finalize, #perform_action, #receive_action, #setup, #stop

Methods included from Logging

included

Methods inherited from Hanuman::Stage

#clone

Methods included from Hanuman::StageClassMethods

#builder, #label, #register, #set_builder

Methods included from Hanuman::StageInstanceMethods

#add_link, #linkable_name, #root

Instance Method Details

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

Yields the input record deserialized from TSV.

Parameters:

Yields:

  • (obj) —

    the deserialized object

Yield Parameters:

  • obj (Object) 


137
138
139
140
141
142
143
144
145
146
 
# File 'lib/wukong/widget/serializers.rb', line 137

def process(record)
  if record.respond_to?(:from_tsv)
    obj = record.from_tsv
  else
    obj = record.split(/\t/)
  end
  yield obj
rescue => e        
  handle_error(record, e)
end