Class: Chicago::ETL::ArraySource

Inherits:

PipelineEndpoint

Object
PipelineEndpoint
Chicago::ETL::ArraySource

Defined in:: lib/chicago/etl/array_source.rb

Instance Attribute Summary

Attributes inherited from PipelineEndpoint

Instance Method Summary collapse

#each ⇒ Object
#initialize(array, fields = []) ⇒ ArraySource constructor

A new instance of ArraySource.

Methods inherited from PipelineEndpoint

#has_defined_fields?

Constructor Details

#initialize(array, fields = []) ⇒ `ArraySource`

Returns a new instance of ArraySource.

# File 'lib/chicago/etl/array_source.rb', line 5

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

Instance Method Details

#each ⇒ `Object`



10
11
12

# File 'lib/chicago/etl/array_source.rb', line 10

def each
  @array.each {|row| yield row }
end