class Sawmill::RecordProcessor::Decompose

A processor that decomposes records into constituent entries and passes those entries to an entry processor.

Public Class Methods

new(processor_, opts_={}) click to toggle source

Create a new decomposer that emits to the given entry processor.

# File lib/sawmill/record_processor/decompose.rb, line 50
def initialize(processor_, opts_={})
  @processor = processor_
  @classifier = EntryClassifier.new(processor_)
end

Public Instance Methods

extra_entry(entry_) click to toggle source

# File lib/sawmill/record_processor/decompose.rb, line 61
def extra_entry(entry_)
  @classifier.entry(entry_)
  true
end

finish() click to toggle source

# File lib/sawmill/record_processor/decompose.rb, line 66
def finish
  @processor.finish
end

record(record_) click to toggle source

# File lib/sawmill/record_processor/decompose.rb, line 56
def record(record_)
  record_.each_entry{ |entry_| @classifier.entry(entry_) }
  true
end