public class DataMappingReader extends IntegrationProxyReader
DataEndpoint.State
fieldLineage, recordLineage
lastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEY
BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZE
id, log, name, TIMESTAMP_FORMAT
Constructor and Description |
---|
DataMappingReader(DataReader nestedDataReader,
DataMapping dataMapping) |
DataMappingReader(DataReader nestedDataReader,
DataMapping dataMapping,
DataWriter discardWriter,
String discardReasonFieldName) |
Modifier and Type | Method and Description |
---|---|
DataException |
addExceptionProperties(DataException exception)
Adds this endpoint's current state to a
DataException . |
void |
close()
Indicates that this endpoint has finished reading or writing.
|
DataMapping |
getDataMapping() |
RecordExpressionContext |
getExpressionContext() |
protected Record |
interceptRecord(Record record) |
boolean |
isLineageSupported() |
boolean |
isSendSkippedToDiscardWriter() |
protected Record |
onFailure(Record record,
DataException exception,
DataMappingResult result) |
void |
open()
Makes this endpoint ready for reading or writing.
|
DataMappingReader |
setSendSkippedToDiscardWriter(boolean sendSkippedToDiscardWriter) |
available, getNestedReader, map, map, readImpl, setNestedDataReader, setNestedDataReader
addLineage, getBufferSize, getNestedEndpoint, getRootEndpoint, getRootReader, isExhausted, isSaveLineage, peek, pop, push, read, setSaveLineage, skip
decrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, incrementRecordCount, isRecordCountBigInteger, resetRecordCount, toString
addElapsedtime, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime, setDescription
public DataMappingReader(DataReader nestedDataReader, DataMapping dataMapping, DataWriter discardWriter, String discardReasonFieldName)
public DataMappingReader(DataReader nestedDataReader, DataMapping dataMapping)
public RecordExpressionContext getExpressionContext()
public DataMapping getDataMapping()
public void open() throws DataException
DataEndpoint
open
in class IntegrationProxyReader
DataException
public void close() throws DataException
DataEndpoint
close
in class ProxyReader
DataException
public boolean isLineageSupported()
isLineageSupported
in class DataReader
protected Record interceptRecord(Record record) throws Throwable
interceptRecord
in class ProxyReader
Throwable
protected Record onFailure(Record record, DataException exception, DataMappingResult result)
public DataException addExceptionProperties(DataException exception)
Endpoint
DataException
. Since this method is called whenever an
exception is thrown, subclasses should override it to add their specific information.addExceptionProperties
in class ProxyReader
public boolean isSendSkippedToDiscardWriter()
public DataMappingReader setSendSkippedToDiscardWriter(boolean sendSkippedToDiscardWriter)
Copyright (c) 2006-2023 North Concepts Inc. All Rights Reserved.