Package org.apache.nifi.queryrecord

Class RecordDataSource

java.lang.Object

org.apache.nifi.queryrecord.RecordDataSource

All Implemented Interfaces:

ResettableDataSource

public class RecordDataSource
extends Object
implements ResettableDataSource

Field Summary

Fields

Modifier and Type	Field	Description
private final org.apache.nifi.flowfile.FlowFile	flowFile
private final org.apache.nifi.logging.ComponentLog	logger
private final RecordReaderFactory	readerFactory
private final org.apache.nifi.processor.ProcessSession	session
private final NiFiTableSchema	tableSchema

Constructor Summary

Constructors

Constructor	Description
RecordDataSource(RecordSchema recordSchema, org.apache.nifi.processor.ProcessSession session, org.apache.nifi.flowfile.FlowFile flowFile, RecordReaderFactory recordReaderFactory, org.apache.nifi.logging.ComponentLog logger)

Method Summary

Modifier and Type	Method	Description
static NiFiTableSchema	createTableSchema(RecordSchema recordSchema)
private static ColumnType	getChoiceColumnType(DataType fieldType)
static ColumnType	getColumnType(DataType fieldType)
NiFiTableSchema	getSchema()
private static boolean	isNumeric(DataType dataType)
RowStream	reset()

Methods inherited from class java.lang.Object

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

Field Details

tableSchema

private final NiFiTableSchema tableSchema

session

private final org.apache.nifi.processor.ProcessSession session

flowFile

private final org.apache.nifi.flowfile.FlowFile flowFile

readerFactory

private final RecordReaderFactory readerFactory

logger

private final org.apache.nifi.logging.ComponentLog logger

Constructor Details

RecordDataSource

public RecordDataSource(RecordSchema recordSchema,
 org.apache.nifi.processor.ProcessSession session,
 org.apache.nifi.flowfile.FlowFile flowFile,
 RecordReaderFactory recordReaderFactory,
 org.apache.nifi.logging.ComponentLog logger)

Method Details

getSchema

public NiFiTableSchema getSchema()

Specified by:

getSchema in interface ResettableDataSource

reset

public RowStream reset()
                throws IOException

Specified by:

reset in interface ResettableDataSource

Throws:

IOException

createTableSchema

public static NiFiTableSchema createTableSchema(RecordSchema recordSchema)

getColumnType

public static ColumnType getColumnType(DataType fieldType)

getChoiceColumnType

private static ColumnType getChoiceColumnType(DataType fieldType)

isNumeric

private static boolean isNumeric(DataType dataType)