com.northconcepts.datapipeline.foundations.pipeline

Class DataMappingPipeline

java.lang.Object

com.northconcepts.datapipeline.foundations.core.Bean

com.northconcepts.datapipeline.foundations.core.FoundationObject

com.northconcepts.datapipeline.foundations.pipeline.PipelineObject

com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline

com.northconcepts.datapipeline.foundations.pipeline.DataMappingPipeline

All Implemented Interfaces:

DataExceptionContributor, JsonSerializable, RecordSerializable, XmlSerializable, DataReaderFactory, DataWriterFactory, JavaCodeGenerator, Serializable

public class DataMappingPipeline
extends AbstractPipeline

See Also:

Serialized Form

Field Summary

Fields inherited from class com.northconcepts.datapipeline.foundations.core.FoundationObject

internalId, internalName, log, TIMESTAMP_FORMAT

Fields inherited from interface com.northconcepts.datapipeline.core.RecordSerializable

SERIALIZED_CLASS_NAME, TYPE

Fields inherited from interface com.northconcepts.datapipeline.core.XmlSerializable

XML_SERIALIZED_CLASS_NAME

Constructor Summary

Constructors

Constructor and Description
DataMappingPipeline()

Method Summary

Modifier and Type	Method and Description
protected DataReader	applyDataProcessingImpl(DataReader reader)
DataMappingPipeline	fromJson(InputStream inputStream)
DataMappingPipeline	fromJson(String jsonString)
DataMappingPipeline	fromRecord(Record source) Loads this instance's state from a record and returns this (for fluid API call chaining).
DataMappingPipeline	fromXml(InputStream inputStream)
DataMappingPipeline	fromXml(String xml)
DataMappingPipeline	fromXmlElement(Element dataMappingPipelineElement)
void	generateJavaCodeImpl(JavaCodeBuilder code)
DataMapping	getDataMapping()
boolean	isSendSkippedToDiscardWriter()
DataMappingPipeline	setDataMapping(DataMapping dataMapping)
DataMappingPipeline	setDescription(String description)
DataMappingPipeline	setDiscardReasonFieldName(String discardReasonFieldName)
DataMappingPipeline	setDiscardWriter(DataWriter discardWriter)
DataMappingPipeline	setInput(PipelineInput input)
DataMappingPipeline	setInputAsDataReader(DataReader reader)
DataMappingPipeline	setInputAsDataReaderFactory(DataReaderFactory factory)
DataMappingPipeline	setMultithreaded(boolean multithreaded)
DataMappingPipeline	setName(String name)
DataMappingPipeline	setOutput(PipelineOutput output)
DataMappingPipeline	setOutputAsDataWriter(DataWriter writer)
DataMappingPipeline	setOutputAsDataWriterFactory(DataWriterFactory factory)
DataMappingPipeline	setSendSkippedToDiscardWriter(boolean sendSkippedToDiscardWriter)
DataMappingPipeline	setSourceEntity(EntityDef sourceEntity)
DataMappingPipeline	setTargetEntity(EntityDef targetEntity)
String	toJson()
DataMappingPipeline	toJson(Writer writer)
DataMappingPipeline	toJson(Writer writer, boolean closeWriter)
Record	toRecord()
DataMappingPipeline	toXml(Writer writer)
DataMappingPipeline	toXml(Writer writer, boolean closeWriter)
Element	toXmlElement(Document document)

Methods inherited from class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline

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

Methods inherited from class com.northconcepts.datapipeline.foundations.core.FoundationObject

addExceptionProperties, assertValid, assertValid, clone, exception, exception, exception, getInternalId, getInternalName, resetInternalId

Methods inherited from class com.northconcepts.datapipeline.foundations.core.Bean

toString

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.northconcepts.datapipeline.core.RecordSerializable

fromArrayValue, fromArrayValue, fromArrayValue, newInstanceFromRecord, newInstanceFromRecord, toArrayValue, toRecord

Methods inherited from interface com.northconcepts.datapipeline.core.JsonSerializable

newInstanceFromJson

Methods inherited from interface com.northconcepts.datapipeline.core.XmlSerializable

forEachGrandChildElement, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getChildElement, getChildElements, newInstanceFromXml, newInstanceFromXml, setAttribute, toXml, toXml, toXml, writeXml, writeXml

Methods inherited from interface com.northconcepts.datapipeline.core.DataExceptionContributor

addExceptionProperties, contributeExceptionProperties, contributeExceptionProperties

Constructor Detail

DataMappingPipeline

public DataMappingPipeline()

Method Detail

getDataMapping

public DataMapping getDataMapping()

setDataMapping

public DataMappingPipeline setDataMapping(DataMapping dataMapping)

applyDataProcessingImpl

protected DataReader applyDataProcessingImpl(DataReader reader)

Specified by:

applyDataProcessingImpl in class AbstractPipeline

generateJavaCodeImpl

public void generateJavaCodeImpl(JavaCodeBuilder code)

Specified by:

generateJavaCodeImpl in class AbstractPipeline

toRecord

public Record toRecord()

Specified by:

toRecord in interface RecordSerializable

Overrides:

toRecord in class AbstractPipeline

fromRecord

public DataMappingPipeline fromRecord(Record source)

Description copied from interface: RecordSerializable

Loads this instance's state from a record and returns this (for fluid API call chaining). For fluid API call chaining, the overridden method should change the declared return type to its class.

Specified by:

fromRecord in interface RecordSerializable

Overrides:

fromRecord in class AbstractPipeline

Returns:

this instance.

fromJson

public DataMappingPipeline fromJson(String jsonString)

Specified by:

fromJson in interface JsonSerializable

Specified by:

fromJson in interface RecordSerializable

Overrides:

fromJson in class AbstractPipeline

fromJson

public DataMappingPipeline fromJson(InputStream inputStream)

toJson

public String toJson()

toJson

public DataMappingPipeline toJson(Writer writer)

toJson

public DataMappingPipeline toJson(Writer writer,
                                  boolean closeWriter)

fromXml

public DataMappingPipeline fromXml(InputStream inputStream)

fromXml

public DataMappingPipeline fromXml(String xml)

toXml

public DataMappingPipeline toXml(Writer writer)

toXml

public DataMappingPipeline toXml(Writer writer,
                                 boolean closeWriter)

setName

public DataMappingPipeline setName(String name)

Overrides:

setName in class AbstractPipeline

setDescription

public DataMappingPipeline setDescription(String description)

Overrides:

setDescription in class AbstractPipeline

setInput

public DataMappingPipeline setInput(PipelineInput input)

Overrides:

setInput in class AbstractPipeline

setInputAsDataReaderFactory

public DataMappingPipeline setInputAsDataReaderFactory(DataReaderFactory factory)

Overrides:

setInputAsDataReaderFactory in class AbstractPipeline

setInputAsDataReader

public DataMappingPipeline setInputAsDataReader(DataReader reader)

Overrides:

setInputAsDataReader in class AbstractPipeline

setOutput

public DataMappingPipeline setOutput(PipelineOutput output)

Overrides:

setOutput in class AbstractPipeline

setOutputAsDataWriterFactory

public DataMappingPipeline setOutputAsDataWriterFactory(DataWriterFactory factory)

Overrides:

setOutputAsDataWriterFactory in class AbstractPipeline

setOutputAsDataWriter

public DataMappingPipeline setOutputAsDataWriter(DataWriter writer)

Overrides:

setOutputAsDataWriter in class AbstractPipeline

setSourceEntity

public DataMappingPipeline setSourceEntity(EntityDef sourceEntity)

Overrides:

setSourceEntity in class AbstractPipeline

setTargetEntity

public DataMappingPipeline setTargetEntity(EntityDef targetEntity)

Overrides:

setTargetEntity in class AbstractPipeline

setMultithreaded

public DataMappingPipeline setMultithreaded(boolean multithreaded)

Overrides:

setMultithreaded in class AbstractPipeline

setDiscardWriter

public DataMappingPipeline setDiscardWriter(DataWriter discardWriter)

Overrides:

setDiscardWriter in class AbstractPipeline

setDiscardReasonFieldName

public DataMappingPipeline setDiscardReasonFieldName(String discardReasonFieldName)

Overrides:

setDiscardReasonFieldName in class AbstractPipeline

isSendSkippedToDiscardWriter

public boolean isSendSkippedToDiscardWriter()

setSendSkippedToDiscardWriter

public DataMappingPipeline setSendSkippedToDiscardWriter(boolean sendSkippedToDiscardWriter)

toXmlElement

public Element toXmlElement(Document document)

Specified by:

toXmlElement in interface XmlSerializable

Overrides:

toXmlElement in class AbstractPipeline

fromXmlElement

public DataMappingPipeline fromXmlElement(Element dataMappingPipelineElement)

Specified by:

fromXmlElement in interface XmlSerializable

Overrides:

fromXmlElement in class AbstractPipeline