com.northconcepts.datapipeline.foundations.pipeline.output.DataWriterPipelineOutput

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

public class DataWriterPipelineOutput extends PipelineOutput

Writes a pipeline's records to the DataWriter created by a DataWriterFactory. It does not support record or XML serialization.

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

DataWriterPipelineOutput()

Creates an output with no factory; call setFactory(DataWriterFactory) before createDataWriter().

DataWriterPipelineOutput(DataWriterFactory factory)
Method Summary

Modifier and Type

Method

Description

DataWriter

createDataWriter()

DataWriterPipelineOutput

fromRecord(Record source)

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

void

generateJavaCode(JavaCodeBuilder javaCodeBuilder)

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

DataWriterFactory

getFactory()

String

getName()

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

DataWriterPipelineOutput

setFactory(DataWriterFactory factory)

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.PipelineOutput
getNestedPipelineOutput, getPipelineOutput, getRootPipelineOutput

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, fromXmlElement, toXml, toXml, toXml, toXml, toXml

Constructor Details
- DataWriterPipelineOutput
  
  public DataWriterPipelineOutput()
  
  Creates an output with no factory; call setFactory(DataWriterFactory) before createDataWriter().
- DataWriterPipelineOutput
  
  public DataWriterPipelineOutput(DataWriterFactory factory)
Method Details
- getName
  
  public String getName()
  
  Description copied from class: PipelineOutput
  
  Returns a display name for this output, such as the destination's name followed by its format.
  
  Specified by:
  
  getName in class PipelineOutput
- generateJavaCode
  
  public void generateJavaCode(JavaCodeBuilder javaCodeBuilder)
  
  Description copied from interface: JavaCodeGenerator
  
  Appends Java source code representing this object to the given builder.
- createDataWriter
  
  public DataWriter createDataWriter()
- getFactory
  
  public DataWriterFactory getFactory()
- setFactory
  
  public DataWriterPipelineOutput setFactory(DataWriterFactory factory)
- 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 Bean
- fromRecord
  
  public DataWriterPipelineOutput 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 PipelineOutput
  
  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 PipelineOutput

Class DataWriterPipelineOutput

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

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

DataWriterPipelineOutput

DataWriterPipelineOutput

Method Details

getName

generateJavaCode

createDataWriter

getFactory

setFactory

toRecord

fromRecord

toXmlElement