Class: Wukong::Processor::ToDelimited

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

Overview

A widget for serializing inputs to a delimited format.

Examples:

Serializing to a delimited format at the end of a data flow


Wukong.dataflow(:emits_delimited) do
  ... | to_delimited(delimiter: "--")
end

See Also:

Constant Summary

Constants inherited from Wukong::Processor

SerializerError

Instance Method Summary collapse

Methods inherited from Serializer

#handle_error

Methods inherited from Wukong::Processor

configure, consumes, description, #expected_record_type, #expected_serialization, #finalize, #perform_action, produces, #receive_action, #setup, #stop, valid_serializer?, validate_and_set_serialization

Methods included from Logging

included

Methods included from Hanuman::StageClassMethods

#builder, #label, #register, #set_builder

Instance Method Details

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

Yields the input record serialized in a delimited format..

Parameters:

  • record (Object)

Yields:

  • (delimited) —

    the serialized delimited output

Yield Parameters:



222
223
224
225
226
227
228
229
230
 
# File 'lib/wukong/widget/serializers.rb', line 222

def process(record)
  begin
    delimited = record.map(&:to_s).join(delimiter)
  rescue => e
    # FIXME -- should we log here or what?
    return
  end
  yield delimited
end