Module: Wukong::Streamer::Filter

Defined in:
lib/wukong/streamer/filter.rb

Overview

emit only some records, as dictated by the #emit? method

This is a mixin: including this module in your streamer implements its #process method.

Instance Method Summary collapse

Instance Method Details

#process(*record) {|record| ... } ⇒ Object

Filter out a subset of record/lines

Subclass and re-define the emit? method

Yields:

  • (record) 


15
16
17
 
# File 'lib/wukong/streamer/filter.rb', line 15

def process *record
  yield record if emit?(*record)
end