module Hasta::IdentityMapper

Used by any EMR job that required an identity mapper

Public Class Methods

map(_, data_sources, data_sink = InMemoryDataSink.new) click to toggle source
# File lib/hasta/identity_mapper.rb, line 8
def self.map(_, data_sources, data_sink = InMemoryDataSink.new)
  Hasta.logger.debug "Starting Identity Mapper"
  CombinedDataSource.new(data_sources).each_line do |line|
    data_sink << line.rstrip
  end

  data_sink.close.tap { Hasta.logger.debug "Finished Identity Mapper" }
end