Package org.apache.nifi.processors.standard

Class LookupRecord.LookupContext

java.lang.Object

org.apache.nifi.processors.standard.LookupRecord.LookupContext

Enclosing class:

LookupRecord

protected static class LookupRecord.LookupContext
extends Object

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 Map<String,RecordPath>	recordPathsByCoordinateKey
private final RecordPath	resultRecordPath
private final org.apache.nifi.processor.ProcessSession	session
private final RecordSetWriterFactory	writerFactory
private final Map<org.apache.nifi.processor.Relationship,Tuple<org.apache.nifi.flowfile.FlowFile,RecordSetWriter>>	writersByRelationship

Constructor Summary

Constructors

Constructor	Description
LookupContext(Map<String,RecordPath> recordPathsByCoordinateKey, RecordPath resultRecordPath, org.apache.nifi.processor.ProcessSession session, org.apache.nifi.flowfile.FlowFile flowFile, RecordSetWriterFactory writerFactory, org.apache.nifi.logging.ComponentLog logger)

Method Summary

Modifier and Type	Method	Description
RecordSetWriter	getExistingRecordWriterForRelationship(org.apache.nifi.processor.Relationship relationship)
org.apache.nifi.flowfile.FlowFile	getFlowFileForRelationship(org.apache.nifi.processor.Relationship relationship)
org.apache.nifi.flowfile.FlowFile	getOriginalFlowFile()
Map<String,RecordPath>	getRecordPathsByCoordinateKey()
RecordSetWriter	getRecordWriterForRelationship(org.apache.nifi.processor.Relationship relationship, RecordSchema schema)
private Set<org.apache.nifi.processor.Relationship>	getRelationshipsUsed()
RecordPath	getResultRecordPath()

Methods inherited from class java.lang.Object

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

Field Details

recordPathsByCoordinateKey

private final Map<String,RecordPath> recordPathsByCoordinateKey

resultRecordPath

private final RecordPath resultRecordPath

session

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

flowFile

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

writerFactory

private final RecordSetWriterFactory writerFactory

logger

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

writersByRelationship

private final Map<org.apache.nifi.processor.Relationship,Tuple<org.apache.nifi.flowfile.FlowFile,RecordSetWriter>> writersByRelationship

Constructor Details

LookupContext

public LookupContext(Map<String,RecordPath> recordPathsByCoordinateKey,
 RecordPath resultRecordPath,
 org.apache.nifi.processor.ProcessSession session,
 org.apache.nifi.flowfile.FlowFile flowFile,
 RecordSetWriterFactory writerFactory,
 org.apache.nifi.logging.ComponentLog logger)

Method Details

getRecordPathsByCoordinateKey

public Map<String,RecordPath> getRecordPathsByCoordinateKey()

getResultRecordPath

public RecordPath getResultRecordPath()

getOriginalFlowFile

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

getRelationshipsUsed

private Set<org.apache.nifi.processor.Relationship> getRelationshipsUsed()

getFlowFileForRelationship

public org.apache.nifi.flowfile.FlowFile getFlowFileForRelationship(org.apache.nifi.processor.Relationship relationship)

getExistingRecordWriterForRelationship

public RecordSetWriter getExistingRecordWriterForRelationship(org.apache.nifi.processor.Relationship relationship)

getRecordWriterForRelationship

public RecordSetWriter getRecordWriterForRelationship(org.apache.nifi.processor.Relationship relationship,
 RecordSchema schema)
                                               throws IOException,
SchemaNotFoundException

Throws:

IOException

SchemaNotFoundException