Class: Hasta::Mapper
- Inherits:
-
Object
- Object
- Hasta::Mapper
- Defined in:
- lib/hasta/mapper.rb
Overview
A wrapper for instantiating a mapper from a definition file and invoking it
Instance Attribute Summary collapse
-
#mapper_file ⇒ Object
readonly
Returns the value of attribute mapper_file.
Instance Method Summary collapse
-
#initialize(mapper_file) ⇒ Mapper
constructor
A new instance of Mapper.
- #map(execution_context, data_sources, data_sink = InMemoryDataSink.new('Mapper Output')) ⇒ Object
Constructor Details
#initialize(mapper_file) ⇒ Mapper
Returns a new instance of Mapper.
12 13 14 |
# File 'lib/hasta/mapper.rb', line 12 def initialize(mapper_file) @mapper_file = mapper_file end |
Instance Attribute Details
#mapper_file ⇒ Object (readonly)
Returns the value of attribute mapper_file.
10 11 12 |
# File 'lib/hasta/mapper.rb', line 10 def mapper_file @mapper_file end |
Instance Method Details
#map(execution_context, data_sources, data_sink = InMemoryDataSink.new('Mapper Output')) ⇒ Object
16 17 18 19 20 21 |
# File 'lib/hasta/mapper.rb', line 16 def map(execution_context, data_sources, data_sink = InMemoryDataSink.new('Mapper Output')) Hasta.logger.debug "Starting mapper: #{mapper_file}" data_source = CombinedDataSource.new(data_sources) execution_context.execute(mapper_file, data_source, data_sink) end |