com.northconcepts.datapipeline.foundations.pipeline

Class Pipeline

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.Pipeline

All Implemented Interfaces:

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

public class Pipeline
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
Pipeline()

Method Summary

Modifier and Type	Method and Description
Pipeline	addAction(Integer index, PipelineAction action)
Pipeline	addAction(PipelineAction action)
protected DataReader	applyDataProcessingImpl(DataReader reader)
Pipeline	fromJson(InputStream inputStream)
Pipeline	fromJson(String jsonString)
Pipeline	fromRecord(Record source) Loads this instance's state from a record and returns this (for fluid API call chaining).
Pipeline	fromXml(InputStream inputStream)
Pipeline	fromXml(String xml)
Pipeline	fromXmlElement(Element pipelineElement)
void	generateJavaCodeImpl(JavaCodeBuilder code)
int	getActionCount()
List<PipelineAction>	getActions()
int	getUndoneActionCount()
List<PipelineAction>	getUndoneActions()
PipelineAction	redoLastAction()
Pipeline	setAction(int index, PipelineAction action)
Pipeline	setActions(List<PipelineAction> actions)
Pipeline	setDescription(String description)
Pipeline	setDiscardReasonFieldName(String discardReasonFieldName)
Pipeline	setDiscardWriter(DataWriter discardWriter)
Pipeline	setInput(PipelineInput input)
Pipeline	setInputAsDataReader(DataReader reader)
Pipeline	setInputAsDataReaderFactory(DataReaderFactory factory)
Pipeline	setMultithreaded(boolean multithreaded)
Pipeline	setName(String name)
Pipeline	setOutput(PipelineOutput output)
Pipeline	setOutputAsDataWriter(DataWriter writer)
Pipeline	setOutputAsDataWriterFactory(DataWriterFactory factory)
Pipeline	setSourceEntity(EntityDef sourceEntity)
Pipeline	setTargetEntity(EntityDef targetEntity)
Record	toRecord()
Element	toXmlElement(Document document)
PipelineAction	undoLastAction()

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, toJson, toJson, toJson, 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, toXml, toXml, writeXml, writeXml

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

addExceptionProperties, contributeExceptionProperties, contributeExceptionProperties

Constructor Detail

Pipeline

public Pipeline()

Method Detail

getActions

public List<PipelineAction> getActions()

getUndoneActions

public List<PipelineAction> getUndoneActions()

getActionCount

public int getActionCount()

getUndoneActionCount

public int getUndoneActionCount()

addAction

public Pipeline addAction(PipelineAction action)

addAction

public Pipeline addAction(Integer index,
                          PipelineAction action)

setAction

public Pipeline setAction(int index,
                          PipelineAction action)

setActions

public Pipeline setActions(List<PipelineAction> actions)

undoLastAction

public PipelineAction undoLastAction()

redoLastAction

public PipelineAction redoLastAction()

generateJavaCodeImpl

public void generateJavaCodeImpl(JavaCodeBuilder code)

Specified by:

generateJavaCodeImpl in class AbstractPipeline

applyDataProcessingImpl

protected DataReader applyDataProcessingImpl(DataReader reader)

Specified by:

applyDataProcessingImpl in class AbstractPipeline

toRecord

public Record toRecord()

Specified by:

toRecord in interface RecordSerializable

Overrides:

toRecord in class AbstractPipeline

fromRecord

public Pipeline 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.

toXmlElement

public Element toXmlElement(Document document)

Specified by:

toXmlElement in interface XmlSerializable

Overrides:

toXmlElement in class AbstractPipeline

fromXmlElement

public Pipeline fromXmlElement(Element pipelineElement)

Specified by:

fromXmlElement in interface XmlSerializable

Overrides:

fromXmlElement in class AbstractPipeline

fromXml

public Pipeline fromXml(InputStream inputStream)

fromXml

public Pipeline fromXml(String xml)

fromJson

public Pipeline fromJson(InputStream inputStream)

fromJson

public Pipeline fromJson(String jsonString)

Specified by:

fromJson in interface JsonSerializable

Specified by:

fromJson in interface RecordSerializable

Overrides:

fromJson in class AbstractPipeline

setName

public Pipeline setName(String name)

Overrides:

setName in class AbstractPipeline

setDescription

public Pipeline setDescription(String description)

Overrides:

setDescription in class AbstractPipeline

setInput

public Pipeline setInput(PipelineInput input)

Overrides:

setInput in class AbstractPipeline

setInputAsDataReaderFactory

public Pipeline setInputAsDataReaderFactory(DataReaderFactory factory)

Overrides:

setInputAsDataReaderFactory in class AbstractPipeline

setInputAsDataReader

public Pipeline setInputAsDataReader(DataReader reader)

Overrides:

setInputAsDataReader in class AbstractPipeline

setOutput

public Pipeline setOutput(PipelineOutput output)

Overrides:

setOutput in class AbstractPipeline

setOutputAsDataWriterFactory

public Pipeline setOutputAsDataWriterFactory(DataWriterFactory factory)

Overrides:

setOutputAsDataWriterFactory in class AbstractPipeline

setOutputAsDataWriter

public Pipeline setOutputAsDataWriter(DataWriter writer)

Overrides:

setOutputAsDataWriter in class AbstractPipeline

setSourceEntity

public Pipeline setSourceEntity(EntityDef sourceEntity)

Overrides:

setSourceEntity in class AbstractPipeline

setTargetEntity

public Pipeline setTargetEntity(EntityDef targetEntity)

Overrides:

setTargetEntity in class AbstractPipeline

setMultithreaded

public Pipeline setMultithreaded(boolean multithreaded)

Overrides:

setMultithreaded in class AbstractPipeline

setDiscardWriter

public Pipeline setDiscardWriter(DataWriter discardWriter)

Overrides:

setDiscardWriter in class AbstractPipeline

setDiscardReasonFieldName

public Pipeline setDiscardReasonFieldName(String discardReasonFieldName)

Overrides:

setDiscardReasonFieldName in class AbstractPipeline