Package org.apache.nifi.processors.standard

Interface LookupRecord.ReplacementStrategy

All Known Implementing Classes:

LookupRecord.InPlaceReplacementStrategy, LookupRecord.RecordPathReplacementStrategy

Enclosing class:

LookupRecord

private static interface LookupRecord.ReplacementStrategy

Method Summary

Modifier and Type	Method	Description
RecordSchema	determineResultSchema(RecordReaderFactory readerFactory, RecordPath rootRecordPath, org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session, org.apache.nifi.flowfile.FlowFile flowFile, LookupRecord.LookupContext lookupContext)
int	getLookupCount()
LookupRecord.MatchResult	lookup(Record record, org.apache.nifi.processor.ProcessContext context, LookupRecord.LookupContext lookupContext)

Method Details

lookup

LookupRecord.MatchResult lookup(Record record,
 org.apache.nifi.processor.ProcessContext context,
 LookupRecord.LookupContext lookupContext)

determineResultSchema

RecordSchema determineResultSchema(RecordReaderFactory readerFactory,
 RecordPath rootRecordPath,
 org.apache.nifi.processor.ProcessContext context,
 org.apache.nifi.processor.ProcessSession session,
 org.apache.nifi.flowfile.FlowFile flowFile,
 LookupRecord.LookupContext lookupContext)
                            throws IOException,
SchemaNotFoundException,
MalformedRecordException,
LookupFailureException

Throws:

IOException

SchemaNotFoundException

MalformedRecordException

LookupFailureException

getLookupCount

int getLookupCount()