com.northconcepts.datapipeline.foundations.pipeline.input

Class JsonPipelineInput

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

com.northconcepts.datapipeline.foundations.pipeline.input.FileSourcePipelineInput

com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput

com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput

All Implemented Interfaces:

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

public class JsonPipelineInput
extends XmlPipelineInput

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

Method Summary

Modifier and Type	Method and Description
JsonPipelineInput	addField(String name, String locationPathAsString)
JsonPipelineInput	addField(String name, String locationPathAsString, boolean cascadeValues)
JsonPipelineInput	addField(String name, String locationPathAsString, String cascadeResetLocationPath)
JsonPipelineInput	addField(XmlField xmlField)
JsonPipelineInput	addRecordBreak(String locationPathAsString)
protected XmlReader	createDataReaderImpl(InputStream in)
JsonPipelineInput	fromRecord(Record source) Loads this instance's state from a record and returns this (for fluid API call chaining).
JsonPipelineInput	fromXmlElement(Element pipelineInputElement)
protected void	generateJavaCodeImpl(JavaCodeBuilder code, CodeWriter writer)
String	getName()
boolean	isUseBigDecimal()
JsonPipelineInput	setAutoCloseReader(boolean autoCloseReader)
JsonPipelineInput	setDebug(boolean debug)
JsonPipelineInput	setDuplicateFieldPolicy(XmlReader.DuplicateFieldPolicy duplicateFieldPolicy)
JsonPipelineInput	setFileSource(FileSource fileSource)
JsonPipelineInput	setUseBigDecimal(boolean useBigDecimal)
Record	toRecord()
Element	toXmlElement(Document document)

Methods inherited from class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput

createDataReader, generateJavaCode, getDuplicateFieldPolicy, getFields, getFields, getFileSource, getRecordBreaks, getRecordBreaks, isAutoCloseReader, isDebug, isLineageSupported

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

getNestedPipelineInput, getRootPipelineInput, 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.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, 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

JsonPipelineInput

public JsonPipelineInput()

Method Detail

createDataReaderImpl

protected XmlReader createDataReaderImpl(InputStream in)

Overrides:

createDataReaderImpl in class XmlPipelineInput

setFileSource

public JsonPipelineInput setFileSource(FileSource fileSource)

Overrides:

setFileSource in class XmlPipelineInput

getName

public String getName()

Overrides:

getName in class XmlPipelineInput

isUseBigDecimal

public boolean isUseBigDecimal()

setUseBigDecimal

public JsonPipelineInput setUseBigDecimal(boolean useBigDecimal)

addField

public JsonPipelineInput addField(XmlField xmlField)

Overrides:

addField in class XmlPipelineInput

addField

public JsonPipelineInput addField(String name,
                                  String locationPathAsString)

Overrides:

addField in class XmlPipelineInput

addField

public JsonPipelineInput addField(String name,
                                  String locationPathAsString,
                                  boolean cascadeValues)

Overrides:

addField in class XmlPipelineInput

addField

public JsonPipelineInput addField(String name,
                                  String locationPathAsString,
                                  String cascadeResetLocationPath)

Overrides:

addField in class XmlPipelineInput

addRecordBreak

public JsonPipelineInput addRecordBreak(String locationPathAsString)

Overrides:

addRecordBreak in class XmlPipelineInput

setDuplicateFieldPolicy

public JsonPipelineInput setDuplicateFieldPolicy(XmlReader.DuplicateFieldPolicy duplicateFieldPolicy)

Overrides:

setDuplicateFieldPolicy in class XmlPipelineInput

setAutoCloseReader

public JsonPipelineInput setAutoCloseReader(boolean autoCloseReader)

Overrides:

setAutoCloseReader in class XmlPipelineInput

setDebug

public JsonPipelineInput setDebug(boolean debug)

Overrides:

setDebug in class XmlPipelineInput

generateJavaCodeImpl

protected void generateJavaCodeImpl(JavaCodeBuilder code,
                                    CodeWriter writer)

Overrides:

generateJavaCodeImpl in class XmlPipelineInput

toRecord

public Record toRecord()

Specified by:

toRecord in interface RecordSerializable

Overrides:

toRecord in class XmlPipelineInput

fromRecord

public JsonPipelineInput 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 XmlPipelineInput

Returns:

this instance.

toXmlElement

public Element toXmlElement(Document document)

Specified by:

toXmlElement in interface XmlSerializable

Overrides:

toXmlElement in class XmlPipelineInput

fromXmlElement

public JsonPipelineInput fromXmlElement(Element pipelineInputElement)

Specified by:

fromXmlElement in interface XmlSerializable

Overrides:

fromXmlElement in class XmlPipelineInput