Class: Clusta::Transforms::Import::Mapper

Inherits:

Wukong::Streamer::Base

Object
Wukong::Streamer::Base
Clusta::Transforms::Import::Mapper

show all

Defined in:: lib/clusta/transforms/import.rb

Instance Method Summary collapse

#process(*record) ⇒ Object

Instance Method Details

#process(*record) ⇒ `Object`



15
16
17

# File 'lib/clusta/transforms/import.rb', line 15

def process *record
  emit record.unshift(Settings[:as])
end