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