Package org.apache.nifi.processors.standard

Class LookupRecord.RecordPathReplacementStrategy

java.lang.Object

org.apache.nifi.processors.standard.LookupRecord.RecordPathReplacementStrategy

All Implemented Interfaces:

LookupRecord.ReplacementStrategy

Enclosing class:

LookupRecord

private class LookupRecord.RecordPathReplacementStrategy
extends Object
implements LookupRecord.ReplacementStrategy

Field Summary

Fields

Modifier and Type	Field	Description
private com.github.benmanes.caffeine.cache.Cache<Map<String,Object>,Optional<?>>	cache
private int	lookupCount

Constructor Summary

Constructors

Constructor	Description
RecordPathReplacementStrategy(org.apache.nifi.processor.ProcessContext context)

Method Summary

Modifier and Type	Method	Description
private void	applyLookupResult(Record record, org.apache.nifi.processor.ProcessContext context, LookupRecord.LookupContext lookupContext, Object lookupValue)
private Map<String,Object>	createLookupCoordinates(Record record, LookupRecord.LookupContext lookupContext, boolean logIfNotMatched)
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

cache

private volatile com.github.benmanes.caffeine.cache.Cache<Map<String,Object>,Optional<?>> cache

Constructor Details

RecordPathReplacementStrategy

public RecordPathReplacementStrategy(org.apache.nifi.processor.ProcessContext context)

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

applyLookupResult

private void applyLookupResult(Record record,
 org.apache.nifi.processor.ProcessContext context,
 LookupRecord.LookupContext lookupContext,
 Object lookupValue)

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,
LookupFailureException

Specified by:

determineResultSchema in interface LookupRecord.ReplacementStrategy

Throws:

IOException

SchemaNotFoundException

MalformedRecordException

LookupFailureException

createLookupCoordinates

private Map<String,Object> createLookupCoordinates(Record record,
 LookupRecord.LookupContext lookupContext,
 boolean logIfNotMatched)

getLookupCount

public int getLookupCount()

Specified by:

getLookupCount in interface LookupRecord.ReplacementStrategy