Class: Chicago::ETL::DatasetSource

Inherits:

PipelineEndpoint

• Object
• PipelineEndpoint
• Chicago::ETL::DatasetSource

Defined in:

lib/chicago/etl/dataset_source.rb

Instance Attribute Summary

• #dataset ⇒ Object readonly

Instance Method Summary

• #each ⇒ Object
• #fields ⇒ Object
• #initialize(dataset) ⇒ DatasetSource constructor

  A new instance of DatasetSource.

Methods inherited from PipelineEndpoint

#has_defined_fields?

Constructor Details

#initialize(dataset) ⇒ DatasetSource

Returns a new instance of DatasetSource.

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

def initialize(dataset)
  @dataset = dataset
end

Instance Attribute Details

#dataset ⇒ Object (readonly)

# File 'lib/chicago/etl/dataset_source.rb', line 8

def dataset
  @dataset
end

Instance Method Details

#each ⇒ Object

# File 'lib/chicago/etl/dataset_source.rb', line 14

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

#fields ⇒ Object

# File 'lib/chicago/etl/dataset_source.rb', line 18

def fields
  @dataset.columns
end