com.northconcepts.datapipeline.memory.MapWriter

public class MapWriter extends DataWriter

Copies the values in specific key-value fields to an in-memory Map. See FieldPath for supported field name expressions.

Nested Class Summary

Nested classes/interfaces inherited from class com.northconcepts.datapipeline.core.DataEndpoint
DataEndpoint.State
Field Summary

Fields inherited from class com.northconcepts.datapipeline.core.DataEndpoint
lastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEY

Fields inherited from class com.northconcepts.datapipeline.core.Endpoint
BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZE

Fields inherited from class com.northconcepts.datapipeline.core.DataObject
id, log, name, TIMESTAMP_FORMAT
Constructor Summary

Constructors

Constructor

Description

MapWriter(FieldPath key, FieldPath value, Map<?,?> map)

Creates a writer that puts each record's value field into the map under its key field, replacing any earlier entry with the same key.

MapWriter(String keyFieldPath, String valueFieldPath, Map<?,?> map)

Creates a writer that puts each record's value field into the map under its key field, replacing any earlier entry with the same key.
Method Summary

Modifier and Type

Method

Description

FieldPath

getKey()

Returns the path of the field whose values become the map's keys.

<K, V> Map<K,V>

getMap()

FieldPath

getValue()

Returns the path of the field whose values become the map's values.

protected void

writeImpl(Record record)

Overridden by subclasses to write the specified record to this DataWriter.

Methods inherited from class com.northconcepts.datapipeline.core.DataWriter
addExceptionProperties, available, getNestedEndpoint, getNestedWriter, getRootEndpoint, getRootWriter, getWriter, write

Methods inherited from class com.northconcepts.datapipeline.core.DataEndpoint
close, decrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, incrementRecordCount, isRecordCountBigInteger, open, resetRecordCount, toString

Methods inherited from class com.northconcepts.datapipeline.core.Endpoint
addElapsedtime, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescription

Methods inherited from class com.northconcepts.datapipeline.core.DataObject
exception, exception, exception, getId, getName, resetID

Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- MapWriter
  
  public MapWriter(FieldPath key, FieldPath value, Map<?,?> map)
  
  Creates a writer that puts each record's value field into the map under its key field, replacing any earlier entry with the same key.
- MapWriter
  
  public MapWriter(String keyFieldPath, String valueFieldPath, Map<?,?> map)
  
  Creates a writer that puts each record's value field into the map under its key field, replacing any earlier entry with the same key.
Method Details
- getKey
  
  public FieldPath getKey()
  
  Returns the path of the field whose values become the map's keys.
- getValue
  
  public FieldPath getValue()
  
  Returns the path of the field whose values become the map's values.
- getMap
  
  public <K, V> Map<K,V> getMap()
- writeImpl
  
  protected void writeImpl(Record record) throws Throwable
  
  Description copied from class: DataWriter
  Overridden by subclasses to write the specified record to this DataWriter.
  Contract for subclasses (see also docs/authoring/DataWriter.md):
  
  Do not call this method directly — DataWriter.write(Record) is the template method that wraps exceptions, increments the record count, and attaches the offending record to thrown DataExceptions.
  
  Do not call DataEndpoint.incrementRecordCount() here; DataWriter.write(Record) already does.
  
  Throw raw exceptions; DataWriter.write(Record) wraps them via exception(throwable).setRecord(record).
  Specified by:
  
  writeImpl in class DataWriter
  
  Throws:
  
  Throwable

Class MapWriter

Nested Class Summary

Nested classes/interfaces inherited from class com.northconcepts.datapipeline.core.DataEndpoint

Field Summary

Fields inherited from class com.northconcepts.datapipeline.core.DataEndpoint

Fields inherited from class com.northconcepts.datapipeline.core.Endpoint

Fields inherited from class com.northconcepts.datapipeline.core.DataObject

Constructor Summary

Method Summary

Methods inherited from class com.northconcepts.datapipeline.core.DataWriter

Methods inherited from class com.northconcepts.datapipeline.core.DataEndpoint

Methods inherited from class com.northconcepts.datapipeline.core.Endpoint

Methods inherited from class com.northconcepts.datapipeline.core.DataObject

Methods inherited from class java.lang.Object

Constructor Details

MapWriter

MapWriter

Method Details

getKey

getValue

getMap

writeImpl