Class: Chicago::Flow::Filter

Inherits:

Transformation

• Object
• Transformation
• Chicago::Flow::Filter

Defined in:

lib/chicago/flow/filter.rb

Instance Method Summary

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

  A new instance of Filter.

• #process_row(row) ⇒ Object

Methods inherited from Transformation

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

Constructor Details

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

Returns a new instance of Filter.

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

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

Instance Method Details

#process_row(row) ⇒ Object

# File 'lib/chicago/flow/filter.rb', line 9

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