Class DataMappingPipeline

Method Details

• getDataMapping

  public DataMapping getDataMapping()

• setDataMapping

  public DataMappingPipeline setDataMapping(DataMapping dataMapping)

• applyDataProcessingImpl

  protected DataReader applyDataProcessingImpl(DataReader reader)

  Description copied from class: AbstractPipeline

  Wraps the reader with this pipeline's own processing; called between the source and target entity transformers.

  Specified by:

  applyDataProcessingImpl in class AbstractPipeline

• generateJavaCodeImpl

  public void generateJavaCodeImpl(JavaCodeBuilder code)

  Description copied from class: AbstractPipeline

  Writes the Java code for this pipeline's own processing, between the input and output code.

  Specified by:

  generateJavaCodeImpl in class AbstractPipeline

• 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 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

  Parameters:

  source -

  Returns:

  this instance.

• fromJson

  public DataMappingPipeline fromJson(String jsonString)

  Description copied from interface: JsonSerializable

  Loads this object's state from the given JSON text.

  Specified by:

  fromJson in interface JsonSerializable

  Specified by:

  fromJson in interface RecordSerializable

  Overrides:

  fromJson in class AbstractPipeline

• fromJson

  public DataMappingPipeline fromJson(InputStream inputStream)

  Description copied from interface: JsonSerializable

  Loads this object's state from the UTF-8 encoded JSON in the stream.

• toJson

  public String toJson()

• toJson

  public DataMappingPipeline toJson(Writer writer)

  Description copied from interface: JsonSerializable

  Writes this object as JSON to the writer, then closes the writer.

• toJson

  public DataMappingPipeline toJson(Writer writer, boolean closeWriter)

  Description copied from interface: JsonSerializable

  Writes this object as JSON to the writer, closing the writer afterwards if closeWriter is true.

• fromXml

  public DataMappingPipeline fromXml(InputStream inputStream)

  Description copied from interface: XmlSerializable

  Parses the XML in the stream and loads this object's state from its root element.

• fromXml

  public DataMappingPipeline fromXml(String xml)

• toXml

  public DataMappingPipeline toXml(Writer writer)

  Description copied from interface: XmlSerializable

  Writes this object as indented XML, without a declaration, to the writer and then closes it.

• toXml

  public DataMappingPipeline toXml(Writer writer, boolean closeWriter)

  Description copied from interface: XmlSerializable

  Writes this object as indented XML, without a declaration, to the writer, closing it afterwards if closeWriter is true.

• 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)

  Description copied from class: AbstractPipeline

  Sets the input to a DataReaderPipelineInput that creates its readers with the given factory.

  Overrides:

  setInputAsDataReaderFactory in class AbstractPipeline

• setInputAsDataReader

  public DataMappingPipeline setInputAsDataReader(DataReader reader)

  Description copied from class: AbstractPipeline

  Sets the input to a DataReaderPipelineInput that always returns the given reader instance.

  Overrides:

  setInputAsDataReader in class AbstractPipeline

• setOutput

  public DataMappingPipeline setOutput(PipelineOutput output)

  Overrides:

  setOutput in class AbstractPipeline

• setOutputAsDataWriterFactory

  public DataMappingPipeline setOutputAsDataWriterFactory(DataWriterFactory factory)

  Description copied from class: AbstractPipeline

  Sets the output to a DataWriterPipelineOutput that creates its writers with the given factory.

  Overrides:

  setOutputAsDataWriterFactory in class AbstractPipeline

• setOutputAsDataWriter

  public DataMappingPipeline setOutputAsDataWriter(DataWriter writer)

  Description copied from class: AbstractPipeline

  Sets the output to a DataWriterPipelineOutput that always returns the given writer instance.

  Overrides:

  setOutputAsDataWriter in class AbstractPipeline

• setSourceEntity

  public DataMappingPipeline setSourceEntity(EntityDef sourceEntity)

  Description copied from class: AbstractPipeline

  Sets the schema entity used to convert and validate records read from the input, before any processing (null for none).

  Overrides:

  setSourceEntity in class AbstractPipeline

• setTargetEntity

  public DataMappingPipeline setTargetEntity(EntityDef targetEntity)

  Description copied from class: AbstractPipeline

  Sets the schema entity used to convert and validate records after processing, before they are written (null for none).

  Overrides:

  setTargetEntity in class AbstractPipeline

• setMultithreaded

  public DataMappingPipeline setMultithreaded(boolean multithreaded)

  Description copied from class: AbstractPipeline

  Indicates if each processing stage runs in its own thread using an AsyncReader (defaults to true).

  Overrides:

  setMultithreaded in class AbstractPipeline

• setDiscardWriter

  public DataMappingPipeline setDiscardWriter(DataWriter discardWriter)

  Description copied from class: AbstractPipeline

  Sets the writer that receives records failing source or target entity validation, instead of stopping the pipeline.

  Overrides:

  setDiscardWriter in class AbstractPipeline

• setDiscardReasonFieldName

  public DataMappingPipeline setDiscardReasonFieldName(String discardReasonFieldName)

  Description copied from class: AbstractPipeline

  Sets the name of the field added to discarded records to hold the failure message; only allowed with a discard writer.

  Overrides:

  setDiscardReasonFieldName in class AbstractPipeline

• isSendSkippedToDiscardWriter

  public boolean isSendSkippedToDiscardWriter()

  Indicates if records skipped because a mapping condition failed are also sent to the discard writer (defaults to false).

• setSendSkippedToDiscardWriter

  public DataMappingPipeline setSendSkippedToDiscardWriter(boolean sendSkippedToDiscardWriter)

  Indicates if records skipped because a mapping condition failed are also sent to the discard writer (defaults to false).

• 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 AbstractPipeline

• fromXmlElement

  public DataMappingPipeline fromXmlElement(Element dataMappingPipelineElement)

  Specified by:

  fromXmlElement in interface XmlSerializable

  Overrides:

  fromXmlElement in class AbstractPipeline