Class: Chicago::Flow::DatasetSource

Inherits:

PipelineEndpoint

• Object
• PipelineEndpoint
• Chicago::Flow::DatasetSource

Defined in:

lib/chicago/flow/dataset_source.rb

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/flow/dataset_source.rb', line 7

def initialize(dataset)
  @dataset = dataset
end

Instance Method Details

#each ⇒ Object

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

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

#fields ⇒ Object

# File 'lib/chicago/flow/dataset_source.rb', line 15

def fields
  @dataset.columns
end