Class: Chicago::ETL::Filter

Inherits:

Object
Transformation
Chicago::ETL::Filter

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

Instance Method Summary collapse

#initialize(stream = :default, &block) ⇒ Filter constructor

A new instance of Filter.
#process_row(row) ⇒ Object

Methods inherited from Transformation

#added_fields, added_fields, adds_fields, #applies_to_stream?, #downstream_fields, #flush, #output_streams, #process, removed_fields, #removed_fields, removes_fields, #required_options, required_options, requires_options, #upstream_fields

Constructor Details

#initialize(stream = :default, &block) ⇒ `Filter`

Returns a new instance of Filter.

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

def initialize(stream=:default, &block)
  super(stream)
  @block = block || lambda {|row| false }
end

Instance Method Details

#process_row(row) ⇒ `Object`



10
11
12

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

def process_row(row)
  row if @block.call(row)
end