public class DataMappingPipeline extends AbstractPipeline
internalId, internalName, log, TIMESTAMP_FORMAT
SERIALIZED_CLASS_NAME, TYPE
XML_SERIALIZED_CLASS_NAME
Constructor and Description |
---|
DataMappingPipeline() |
applyDataProcessing, applySourceEntityTransformer, applyTargetEntityTransformer, createDataReader, createDataWriter, createJob, generateJavaCode, generateJavaCodePostProcess, generateJavaCodePreProcess, getDateTimePatternDetector, getDescription, getDiscardReasonFieldName, getDiscardWriter, getInput, getJavaCode, getName, getNumberDetector, getOutput, getSourceEntity, getTargetEntity, isMultithreaded, run, runAsync, setDateTimePatternDetector, setNumberDetector
addExceptionProperties, assertValid, assertValid, clone, exception, exception, exception, getInternalId, getInternalName, resetInternalId
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
fromArrayValue, fromArrayValue, fromArrayValue, newInstanceFromRecord, newInstanceFromRecord, toArrayValue, toRecord
newInstanceFromJson
forEachGrandChildElement, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getChildElement, getChildElements, newInstanceFromXml, newInstanceFromXml, setAttribute, toXml, toXml, toXml, writeXml, writeXml
addExceptionProperties, contributeExceptionProperties, contributeExceptionProperties
public DataMapping getDataMapping()
public DataMappingPipeline setDataMapping(DataMapping dataMapping)
protected DataReader applyDataProcessingImpl(DataReader reader)
applyDataProcessingImpl
in class AbstractPipeline
public void generateJavaCodeImpl(JavaCodeBuilder code)
generateJavaCodeImpl
in class AbstractPipeline
public Record toRecord()
toRecord
in interface RecordSerializable
toRecord
in class AbstractPipeline
public DataMappingPipeline fromRecord(Record source)
RecordSerializable
this
(for fluid API call chaining).
For fluid API call chaining, the overridden method should change the declared return type to its class.fromRecord
in interface RecordSerializable
fromRecord
in class AbstractPipeline
public DataMappingPipeline fromJson(String jsonString)
fromJson
in interface JsonSerializable
fromJson
in interface RecordSerializable
fromJson
in class AbstractPipeline
public DataMappingPipeline fromJson(InputStream inputStream)
public String toJson()
public DataMappingPipeline toJson(Writer writer)
public DataMappingPipeline toJson(Writer writer, boolean closeWriter)
public DataMappingPipeline fromXml(InputStream inputStream)
public DataMappingPipeline fromXml(String xml)
public DataMappingPipeline toXml(Writer writer)
public DataMappingPipeline toXml(Writer writer, boolean closeWriter)
public DataMappingPipeline setName(String name)
setName
in class AbstractPipeline
public DataMappingPipeline setDescription(String description)
setDescription
in class AbstractPipeline
public DataMappingPipeline setInput(PipelineInput input)
setInput
in class AbstractPipeline
public DataMappingPipeline setInputAsDataReaderFactory(DataReaderFactory factory)
setInputAsDataReaderFactory
in class AbstractPipeline
public DataMappingPipeline setInputAsDataReader(DataReader reader)
setInputAsDataReader
in class AbstractPipeline
public DataMappingPipeline setOutput(PipelineOutput output)
setOutput
in class AbstractPipeline
public DataMappingPipeline setOutputAsDataWriterFactory(DataWriterFactory factory)
setOutputAsDataWriterFactory
in class AbstractPipeline
public DataMappingPipeline setOutputAsDataWriter(DataWriter writer)
setOutputAsDataWriter
in class AbstractPipeline
public DataMappingPipeline setSourceEntity(EntityDef sourceEntity)
setSourceEntity
in class AbstractPipeline
public DataMappingPipeline setTargetEntity(EntityDef targetEntity)
setTargetEntity
in class AbstractPipeline
public DataMappingPipeline setMultithreaded(boolean multithreaded)
setMultithreaded
in class AbstractPipeline
public DataMappingPipeline setDiscardWriter(DataWriter discardWriter)
setDiscardWriter
in class AbstractPipeline
public DataMappingPipeline setDiscardReasonFieldName(String discardReasonFieldName)
setDiscardReasonFieldName
in class AbstractPipeline
public boolean isSendSkippedToDiscardWriter()
public DataMappingPipeline setSendSkippedToDiscardWriter(boolean sendSkippedToDiscardWriter)
public Element toXmlElement(Document document)
toXmlElement
in interface XmlSerializable
toXmlElement
in class AbstractPipeline
public DataMappingPipeline fromXmlElement(Element dataMappingPipelineElement)
fromXmlElement
in interface XmlSerializable
fromXmlElement
in class AbstractPipeline
Copyright (c) 2006-2024 North Concepts Inc. All Rights Reserved.