Package org.apache.nifi.processors.standard

Class LookupRecord.InPlaceReplacementStrategy

java.lang.Object

org.apache.nifi.processors.standard.LookupRecord.InPlaceReplacementStrategy

All Implemented Interfaces:

LookupRecord.ReplacementStrategy

Enclosing class:

LookupRecord

private class LookupRecord.InPlaceReplacementStrategy
extends Object
implements LookupRecord.ReplacementStrategy

Field Summary

Fields

Modifier and Type	Field	Description
private int	lookupCount

Constructor Summary

Constructors

Modifier	Constructor	Description
private	InPlaceReplacementStrategy()

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)

Methods inherited from class java.lang.Object

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

Field Details

lookupCount

private int lookupCount

Constructor Details

InPlaceReplacementStrategy

private InPlaceReplacementStrategy()

Method Details

lookup

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

Specified by:

lookup in interface LookupRecord.ReplacementStrategy

determineResultSchema

public 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

Specified by:

determineResultSchema in interface LookupRecord.ReplacementStrategy

Throws:

IOException

SchemaNotFoundException

MalformedRecordException

getLookupCount

public int getLookupCount()

Specified by:

getLookupCount in interface LookupRecord.ReplacementStrategy