Sha256: 9fc533f1c279a28f22f7ba9ac81a2c2c09e406b4dac59558772bc8179484a4a8
Contents?: true
Size: 658 Bytes
Versions: 31
Compression:
Stored size: 658 Bytes
Contents
module ETL #:nodoc:
module Processor #:nodoc:
# Row level processor to generate a sequence.
#
# Configuration options:
# * <tt>:context</tt>: A context name, if none is specified then the context will be
# the current ETL run
# * <tt>:dest</tt>: The destination field name
class SequenceProcessor < ETL::Processor::RowProcessor
def process(row)
sequences[configuration[:context]] ||= 0
row[configuration[:dest]] = sequences[configuration[:context]] += 1
row
end
protected
# Get a Hash of sequences
def sequences
@sequences ||= {}
end
end
end
end
Version data entries
31 entries across 31 versions & 9 rubygems