org.apache.nifi.reporting

Class AbstractSiteToSiteReportingTask.JsonRecordReader

java.lang.Object

org.apache.nifi.reporting.AbstractSiteToSiteReportingTask.JsonRecordReader

All Implemented Interfaces:

Closeable, AutoCloseable, RecordReader

Enclosing class:

AbstractSiteToSiteReportingTask

private class AbstractSiteToSiteReportingTask.JsonRecordReader
extends Object
implements RecordReader

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	array
private Supplier<DateFormat>	dateFormat
private com.fasterxml.jackson.databind.JsonNode	firstJsonNode
private boolean	firstObjectConsumed
private com.fasterxml.jackson.core.JsonParser	jsonParser
private RecordSchema	recordSchema
private Supplier<DateFormat>	timeFormat
private Supplier<DateFormat>	timestampFormat

Constructor Summary

Constructors

Constructor and Description
JsonRecordReader(InputStream in, RecordSchema recordSchema)

Method Summary

Modifier and Type	Method and Description
void	close()
protected Object	convertField(com.fasterxml.jackson.databind.JsonNode fieldNode, String fieldName, DataType desiredType, boolean dropUnknown)
private Record	convertJsonNodeToRecord(com.fasterxml.jackson.databind.JsonNode jsonNode, RecordSchema schema, String fieldNamePrefix, boolean coerceTypes, boolean dropUnknown)
private com.fasterxml.jackson.databind.JsonNode	getChildNode(com.fasterxml.jackson.databind.JsonNode jsonNode, RecordField field)
private com.fasterxml.jackson.databind.JsonNode	getNextJsonNode()
protected Object	getRawNodeValue(com.fasterxml.jackson.databind.JsonNode fieldNode, DataType dataType)
RecordSchema	getSchema()
Record	nextRecord(boolean coerceTypes, boolean dropUnknownFields)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.nifi.serialization.RecordReader

createRecordSet, nextRecord

Field Detail

recordSchema

private RecordSchema recordSchema

jsonParser

private final com.fasterxml.jackson.core.JsonParser jsonParser

array

private final boolean array

firstJsonNode

private final com.fasterxml.jackson.databind.JsonNode firstJsonNode

firstObjectConsumed

private boolean firstObjectConsumed

dateFormat

private final Supplier<DateFormat> dateFormat

timeFormat

private final Supplier<DateFormat> timeFormat

timestampFormat

private final Supplier<DateFormat> timestampFormat

Constructor Detail

JsonRecordReader

public JsonRecordReader(InputStream in,
                        RecordSchema recordSchema)
                 throws IOException,
                        MalformedRecordException

Throws:

IOException

MalformedRecordException

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

nextRecord

public Record nextRecord(boolean coerceTypes,
                         boolean dropUnknownFields)
                  throws IOException,
                         MalformedRecordException

Specified by:

nextRecord in interface RecordReader

Throws:

IOException

MalformedRecordException

getSchema

public RecordSchema getSchema()
                       throws MalformedRecordException

Specified by:

getSchema in interface RecordReader

Throws:

MalformedRecordException

getNextJsonNode

private com.fasterxml.jackson.databind.JsonNode getNextJsonNode()
                                                         throws IOException,
                                                                MalformedRecordException

Throws:

IOException

MalformedRecordException

convertJsonNodeToRecord

private Record convertJsonNodeToRecord(com.fasterxml.jackson.databind.JsonNode jsonNode,
                                       RecordSchema schema,
                                       String fieldNamePrefix,
                                       boolean coerceTypes,
                                       boolean dropUnknown)
                                throws IOException,
                                       MalformedRecordException

Throws:

IOException

MalformedRecordException

getChildNode

private com.fasterxml.jackson.databind.JsonNode getChildNode(com.fasterxml.jackson.databind.JsonNode jsonNode,
                                                             RecordField field)

convertField

protected Object convertField(com.fasterxml.jackson.databind.JsonNode fieldNode,
                              String fieldName,
                              DataType desiredType,
                              boolean dropUnknown)
                       throws IOException,
                              MalformedRecordException

Throws:

IOException

MalformedRecordException

getRawNodeValue

protected Object getRawNodeValue(com.fasterxml.jackson.databind.JsonNode fieldNode,
                                 DataType dataType)
                          throws IOException

Throws:

IOException