Package org.apache.nifi.processors.standard.enrichment

Class RecordJoinInput

java.lang.Object

org.apache.nifi.processors.standard.enrichment.RecordJoinInput

public class RecordJoinInput
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final org.apache.nifi.flowfile.FlowFile	flowFile
private final RecordReaderFactory	recordReaderFactory
private final RecordSchema	recordSchema

Constructor Summary

Constructors

Constructor	Description
RecordJoinInput(org.apache.nifi.flowfile.FlowFile flowFile, RecordReaderFactory recordReaderFactory, RecordSchema recordSchema)

Method Summary

Modifier and Type	Method	Description
org.apache.nifi.flowfile.FlowFile	getFlowFile()
RecordReaderFactory	getRecordReaderFactory()
RecordSchema	getRecordSchema()

Methods inherited from class java.lang.Object

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

Field Details

flowFile

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

recordReaderFactory

private final RecordReaderFactory recordReaderFactory

recordSchema

private final RecordSchema recordSchema

Constructor Details

RecordJoinInput

public RecordJoinInput(org.apache.nifi.flowfile.FlowFile flowFile,
 RecordReaderFactory recordReaderFactory,
 RecordSchema recordSchema)

Method Details

getFlowFile

public org.apache.nifi.flowfile.FlowFile getFlowFile()

getRecordReaderFactory

public RecordReaderFactory getRecordReaderFactory()

getRecordSchema

public RecordSchema getRecordSchema()