Class: Chicago::Flow::ArraySink

Inherits:

Sink

• Object
• PipelineEndpoint
• Sink
• Chicago::Flow::ArraySink

Defined in:

lib/chicago/flow/array_sink.rb

Instance Attribute Summary

• #data ⇒ Object readonly

  Returns the value of attribute data.

Attributes inherited from PipelineEndpoint

#fields

Instance Method Summary

• #<<(row) ⇒ Object
• #initialize(fields = []) ⇒ ArraySink constructor

  A new instance of ArraySink.

Methods inherited from Sink

#close, #constant_values, #open

Methods inherited from PipelineEndpoint

#has_defined_fields?

Constructor Details

#initialize(fields = []) ⇒ ArraySink

Returns a new instance of ArraySink.

# File 'lib/chicago/flow/array_sink.rb', line 6

def initialize(fields=[])
  @fields = [fields].flatten
  @data = []
end

Instance Attribute Details

#data ⇒ Object (readonly)

Returns the value of attribute data.

# File 'lib/chicago/flow/array_sink.rb', line 4

def data
  @data
end

Instance Method Details

#<<(row) ⇒ Object

# File 'lib/chicago/flow/array_sink.rb', line 11

def <<(row)
  @data << row.merge(constant_values)
end