com.northconcepts.datapipeline.foundations.pipeline.input.DatasetPipelineInput

All Implemented Interfaces:: DataExceptionContributor, JsonSerializable, RecordSerializable, XmlSerializable, DataReaderFactory, JavaCodeGenerator, Serializable

public class DatasetPipelineInput extends PipelineInput

Reads the source data for a Pipeline or DataMappingPipeline from a Dataset.

See Also:

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

Description

DatasetPipelineInput(Dataset dataset)
Method Summary

Modifier and Type

Method

Description

DataReader

createDataReader()

DatasetPipelineInput

fromRecord(Record source)

Loads this instance's state from a record and returns this (for fluid API call chaining).

XmlSerializable

fromXmlElement(Element element)

void

generateJavaCode(JavaCodeBuilder javaCodeBuilder)

Appends Java source code representing this object to the given builder.

String

getName()

Returns a display name for this input, such as the source's name followed by its format.

Record

toRecord()

Converts this object's state to a record that RecordSerializable.fromRecord(Record) can load.

Element

toXmlElement(Document document)

Returns an element, created with document, describing this object; the default implementation throws a DataException.

Methods inherited from class com.northconcepts.datapipeline.foundations.pipeline.PipelineInput
getNestedPipelineInput, getPipelineInput, getRootPipelineInput, isLineageSupported, isSaveLineage, setSaveLineage

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.DataExceptionContributor
addExceptionProperties

Methods inherited from interface com.northconcepts.datapipeline.core.RecordSerializable
fromJson, fromJson, toJson, toJson, toJson

Methods inherited from interface com.northconcepts.datapipeline.core.XmlSerializable
fromXml, fromXml, toXml, toXml, toXml, toXml, toXml

Constructor Details
- DatasetPipelineInput
  
  public DatasetPipelineInput(Dataset dataset)
Method Details
- createDataReader
  
  public DataReader createDataReader()
- generateJavaCode
  
  public void generateJavaCode(JavaCodeBuilder javaCodeBuilder)
  
  Description copied from interface: JavaCodeGenerator
  
  Appends Java source code representing this object to the given builder.
- getName
  
  public String getName()
  
  Description copied from class: PipelineInput
  
  Returns a display name for this input, such as the source's name followed by its format.
  
  Specified by:
  
  getName in class PipelineInput
- toRecord
  
  public Record toRecord()
  
  Description copied from interface: RecordSerializable
  
  Converts this object's state to a record that RecordSerializable.fromRecord(Record) can load.
  
  Specified by:
  
  toRecord in interface RecordSerializable
  
  Overrides:
  
  toRecord in class PipelineInput
- fromRecord
  
  public DatasetPipelineInput 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 PipelineInput
  
  Parameters:
  
  source -
  
  Returns:
  
  this instance.
- toXmlElement
  
  public Element toXmlElement(Document document)
  
  Description copied from interface: XmlSerializable
  
  Returns an element, created with document, describing this object; the default implementation throws a DataException.
  
  Specified by:
  
  toXmlElement in interface XmlSerializable
  
  Overrides:
  
  toXmlElement in class PipelineInput
- fromXmlElement
  
  public XmlSerializable fromXmlElement(Element element)
  
  Specified by:
  
  fromXmlElement in interface XmlSerializable
  
  Overrides:
  
  fromXmlElement in class PipelineInput

Class DatasetPipelineInput

Field Summary

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

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

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

Constructor Summary

Method Summary

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

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

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

Methods inherited from class java.lang.Object

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

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

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

Constructor Details

DatasetPipelineInput

Method Details

createDataReader

generateJavaCode

getName

toRecord

fromRecord

toXmlElement

fromXmlElement