com.northconcepts.datapipeline.foundations.pipeline

Class PipelineOutput

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

All Implemented Interfaces:

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

Direct Known Subclasses:

DataWriterPipelineOutput, FileSinkPipelineOutput, JdbcPipelineOutput, ProxyPipelineOutput

public abstract class PipelineOutput
extends PipelineObject
implements DataWriterFactory

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
PipelineOutput()

Method Summary

Modifier and Type	Method and Description
PipelineOutput	fromRecord(Record source) Loads this instance's state from a record and returns this (for fluid API call chaining).
abstract String	getName()
PipelineOutput	getNestedPipelineOutput() Returns the PipelineOutput held inside this one or null if there isn't one.
<T extends PipelineOutput> T	getPipelineOutput(Class<T> type) Searches for a nested PipelineOutput of the specified type within this pipeline output hierarchy.
PipelineOutput	getRootPipelineOutput() Returns the deepest, nested PipelineOutput held inside this one, otherwise this instance is returned if there aren't any nested PipelineOutputs.
Element	toXmlElement(Document document)

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

toRecord, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.northconcepts.datapipeline.job.DataWriterFactory

createDataWriter

Methods inherited from interface com.northconcepts.datapipeline.sourcecode.JavaCodeGenerator

generateJavaCode

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

fromArrayValue, fromArrayValue, fromArrayValue, fromJson, fromJson, 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, fromXml, fromXml, fromXmlElement, 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

PipelineOutput

public PipelineOutput()

Method Detail

getName

public abstract String getName()

getNestedPipelineOutput

public PipelineOutput getNestedPipelineOutput()

Returns the PipelineOutput held inside this one or null if there isn't one.

getRootPipelineOutput

public PipelineOutput getRootPipelineOutput()

Returns the deepest, nested PipelineOutput held inside this one, otherwise this instance is returned if there aren't any nested PipelineOutputs.

getPipelineOutput

public <T extends PipelineOutput> T getPipelineOutput(Class<T> type)

Searches for a nested PipelineOutput of the specified type within this pipeline output hierarchy.

This method first checks if the current instance is assignable to the specified type. If not, it traverses through all nested PipelineOutputs to find one that matches the type.

Type Parameters:

T - the type of PipelineOutput to search for

Parameters:

type - the class of the PipelineOutput type to find

Returns:

the first matching PipelineOutput of the specified type, or null if not found

fromRecord

public PipelineOutput 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 Bean

Returns:

this instance.

toXmlElement

public Element toXmlElement(Document document)

Specified by:

toXmlElement in interface XmlSerializable