Class: ETL::Processor::FilterRowProcessor

Inherits:

RowProcessor

• Object
• Processor
• RowProcessor
• ETL::Processor::FilterRowProcessor

show all

Defined in:

lib/etl/processor/filter_row_processor.rb

Instance Attribute Summary (collapse)

• - (Object) condition readonly

  Returns the value of attribute condition.

• - (Object) outfalse readonly

  Returns the value of attribute outfalse.

• - (Object) outtrue readonly

  Returns the value of attribute outtrue.

Instance Method Summary (collapse)

• - (FilterRowProcessor) initialize(control, configuration) constructor

  A new instance of FilterRowProcessor.

• - (Object) process(row)

8
9
10
11
12
13

# File 'lib/etl/processor/filter_row_processor.rb', line 8

def initialize(control, configuration)
  @condition = configuration[:condition]
  @outtrue = configuration[:outtrue]
  @outfalse = configuration[:outfalse]
  super
end

4
5
6

# File 'lib/etl/processor/filter_row_processor.rb', line 4

def condition
  @condition
end

6
7
8

# File 'lib/etl/processor/filter_row_processor.rb', line 6

def outfalse
  @outfalse
end

5
6
7

# File 'lib/etl/processor/filter_row_processor.rb', line 5

def outtrue
  @outtrue
end

15
16
17
18
19
20
21
22
23
24
25
26
27

# File 'lib/etl/processor/filter_row_processor.rb', line 15

def process(row)
  return nil if row.nil?

  if eval_condition(row, @condition)
    return [] if @outtrue.nil?

    eval(@outtrue)
  else
    eval(@outfalse) unless @outfalse.nil?
  end

  return row
end