com.northconcepts.datapipeline.json

Class JsonReader

java.lang.Object

com.northconcepts.datapipeline.core.DataObject

com.northconcepts.datapipeline.core.Endpoint

com.northconcepts.datapipeline.core.DataEndpoint

com.northconcepts.datapipeline.core.DataReader

com.northconcepts.datapipeline.xml.XmlReader

com.northconcepts.datapipeline.json.JsonReader

public class JsonReader
extends XmlReader

Nested Class Summary

Nested classes/interfaces inherited from class com.northconcepts.datapipeline.xml.XmlReader

XmlReader.DuplicateFieldPolicy

Nested classes/interfaces inherited from class com.northconcepts.datapipeline.core.DataEndpoint

DataEndpoint.State

Field Summary

Fields inherited from class com.northconcepts.datapipeline.xml.XmlReader

currentRecord, fields, hasCascadingFields, reader, recordBreaks

Fields inherited from class com.northconcepts.datapipeline.core.DataReader

fieldLineage, recordLineage

Fields inherited from class com.northconcepts.datapipeline.core.DataEndpoint

lastRecord, PRODUCT, PRODUCT_VERSION, VENDOR, XML_INPUT_FACTORY_KEY

Fields inherited from class com.northconcepts.datapipeline.core.Endpoint

BUFFER_SIZE, captureElapsedTime, DEFAULT_READ_BUFFER_SIZE

Fields inherited from class com.northconcepts.datapipeline.core.DataObject

id, log, name, TIMESTAMP_FORMAT

Constructor Summary

Constructors

Constructor and Description
JsonReader(File file)
JsonReader(Reader reader)

Method Summary

Modifier and Type	Method and Description
DataException	addExceptionProperties(DataException exception) Adds this endpoint's current state to a DataException.
JsonReader	addField(String name, String locationPathAsString) Identifies a new field using XPath in the XML stream.
JsonReader	addField(String name, String locationPathAsString, boolean cascadeValues) Identifies a new field using XPath in the XML stream.
JsonReader	addField(String name, String locationPathAsString, String cascadeResetLocationPath) Identifies a new field using XPath in the XML stream.
JsonReader	addField(XmlField field)
protected Record	addLineage(Record record)
JsonReader	addRecordBreak(String locationPathAsString)
boolean	isUseBigDecimal()
JsonReader	setAddTextToParent(boolean addTextToParent) Indicates if each child node's text should be concatenated to its parent during parsing (defaults to false).
JsonReader	setAutoCloseReader(boolean autoCloseReader)
JsonReader	setDebug(boolean debug)
JsonReader	setDescription(String description)
JsonReader	setDuplicateFieldPolicy(XmlReader.DuplicateFieldPolicy duplicateFieldPolicy)
JsonReader	setIgnoreNamespaces(boolean ignoreNamespaces) Indicates if namespaces on elements and attributes are ignored when matching expressions (default to true).
JsonReader	setSaveLineage(boolean saveLineage)
JsonReader	setUseBigDecimal(boolean useBigDecimal)
JsonReader	useBigDecimal(boolean useBigDecimal) Deprecated. Use setUseBigDecimal(boolean) method instead.

Methods inherited from class com.northconcepts.datapipeline.xml.XmlReader

addFieldValue, close, createRecord, expandAndPushRecords, expandListFieldsAsFields, getDuplicateFieldPolicy, getFieldValues, getXmlNodeReader, isAddTextToParent, isAutoCloseReader, isDebug, isIgnoreNamespaces, isLineageSupported, isRecordBreak, open, readImpl, saveAncestorAttributeFieldValues, saveAncestorNodeFieldValues, saveFieldValues, setRecordField

Methods inherited from class com.northconcepts.datapipeline.core.DataReader

available, getBufferSize, getNestedEndpoint, getNestedReader, getRootEndpoint, getRootReader, isExhausted, isSaveLineage, peek, pop, push, read, skip

Methods inherited from class com.northconcepts.datapipeline.core.DataEndpoint

decrementRecordCount, enableJmx, getLastRecord, getRecordCount, getRecordCountAsBigInteger, getRecordCountAsString, incrementRecordCount, isRecordCountBigInteger, resetRecordCount, toString

Methods inherited from class com.northconcepts.datapipeline.core.Endpoint

addElapsedtime, assertClosed, assertNotOpened, assertOpened, finalize, getClosedOn, getDescription, getElapsedTime, getElapsedTimeAsString, getOpenedOn, getOpenElapsedTime, getOpenElapsedTimeAsString, getSelfTime, getSelfTimeAsString, getState, isCaptureElapsedTime, isClosed, isOpen, setCaptureElapsedTime

Methods inherited from class com.northconcepts.datapipeline.core.DataObject

exception, exception, exception, getId, getName, resetID

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

JsonReader

public JsonReader(File file)

JsonReader

public JsonReader(Reader reader)

Method Detail

isUseBigDecimal

public boolean isUseBigDecimal()

useBigDecimal

@Deprecated
public JsonReader useBigDecimal(boolean useBigDecimal)

Deprecated. Use setUseBigDecimal(boolean) method instead.

setUseBigDecimal

public JsonReader setUseBigDecimal(boolean useBigDecimal)

setAutoCloseReader

public JsonReader setAutoCloseReader(boolean autoCloseReader)

Overrides:

setAutoCloseReader in class XmlReader

setDebug

public JsonReader setDebug(boolean debug)

Overrides:

setDebug in class XmlReader

setAddTextToParent

public JsonReader setAddTextToParent(boolean addTextToParent)

Description copied from class: XmlReader

Indicates if each child node's text should be concatenated to its parent during parsing (defaults to false). Setting this to true will result in higher memory consumption.

Overrides:

setAddTextToParent in class XmlReader

addRecordBreak

public JsonReader addRecordBreak(String locationPathAsString)

Overrides:

addRecordBreak in class XmlReader

addField

public JsonReader addField(XmlField field)

Overrides:

addField in class XmlReader

addField

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

Description copied from class: XmlReader

Identifies a new field using XPath in the XML stream.

Overrides:

addField in class XmlReader

Parameters:

name - the field name to create

locationPathAsString - the XPath to match to populate this field

cascadeValues - indicates if this reader should return the last value seen for this field when no matches are available.

addField

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

Description copied from class: XmlReader

Identifies a new field using XPath in the XML stream. If cascadeResetLocationPath is not null and not empty, it will indicate when this field should be cleared, otherwise this field will return the last value seen when no new matches are available.

Overrides:

addField in class XmlReader

Parameters:

name - the field name to create

locationPathAsString - the XPath to match to populate this field

cascadeResetLocationPath - the XPath to identify when cascading values (i.e. the last value seen for this field) should be cleared.

addField

public JsonReader addField(String name,
                           String locationPathAsString)

Description copied from class: XmlReader

Identifies a new field using XPath in the XML stream.

Overrides:

addField in class XmlReader

Parameters:

name - the field name to create

locationPathAsString - the XPath to match to populate this field

setDuplicateFieldPolicy

public JsonReader setDuplicateFieldPolicy(XmlReader.DuplicateFieldPolicy duplicateFieldPolicy)

Overrides:

setDuplicateFieldPolicy in class XmlReader

setIgnoreNamespaces

public JsonReader setIgnoreNamespaces(boolean ignoreNamespaces)

Description copied from class: XmlReader

Indicates if namespaces on elements and attributes are ignored when matching expressions (default to true).

Overrides:

setIgnoreNamespaces in class XmlReader

setSaveLineage

public JsonReader setSaveLineage(boolean saveLineage)

Overrides:

setSaveLineage in class XmlReader

setDescription

public JsonReader setDescription(String description)

Overrides:

setDescription in class XmlReader

addLineage

protected Record addLineage(Record record)

Overrides:

addLineage in class XmlReader

addExceptionProperties

public DataException addExceptionProperties(DataException exception)

Description copied from class: Endpoint

Adds this endpoint's current state to a DataException. Since this method is called whenever an exception is thrown, subclasses should override it to add their specific information.

Overrides:

addExceptionProperties in class XmlReader