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

Class IndexCorrelatedJoinStrategy

java.lang.Object

org.apache.nifi.processors.standard.enrichment.IndexCorrelatedJoinStrategy

All Implemented Interfaces:

RecordJoinStrategy

Direct Known Subclasses:

InsertRecordFieldsJoinStrategy, WrapperJoinStrategy

public abstract class IndexCorrelatedJoinStrategy
extends Object
implements RecordJoinStrategy

Field Summary

Fields

Modifier and Type	Field	Description
private final org.apache.nifi.logging.ComponentLog	logger

Constructor Summary

Constructors

Constructor	Description
IndexCorrelatedJoinStrategy(org.apache.nifi.logging.ComponentLog logger)

Method Summary

Modifier and Type	Method	Description
private void	closeQuietly(AutoCloseable closeable)
private void	closeQuietly(AutoCloseable... closeables)
protected abstract Record	combineRecords(Record originalRecord, Record enrichmentRecord, RecordSchema resultSchema)
protected abstract RecordSchema	createResultSchema(Record firstOriginalRecord, Record firstEnrichmentRecord)
protected org.apache.nifi.logging.ComponentLog	getLogger()
RecordJoinResult	join(RecordJoinInput originalInput, RecordJoinInput enrichmentInput, Map<String,String> combinedAttributes, org.apache.nifi.processor.ProcessSession session, RecordSchema writerSchema)

Methods inherited from class java.lang.Object

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

Field Details

logger

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

Constructor Details

IndexCorrelatedJoinStrategy

public IndexCorrelatedJoinStrategy(org.apache.nifi.logging.ComponentLog logger)

Method Details

getLogger

protected org.apache.nifi.logging.ComponentLog getLogger()

join

public RecordJoinResult join(RecordJoinInput originalInput,
 RecordJoinInput enrichmentInput,
 Map<String,String> combinedAttributes,
 org.apache.nifi.processor.ProcessSession session,
 RecordSchema writerSchema)
                      throws Exception

Specified by:

join in interface RecordJoinStrategy

Throws:

Exception

closeQuietly

private void closeQuietly(AutoCloseable... closeables)

closeQuietly

private void closeQuietly(AutoCloseable closeable)

combineRecords

protected abstract Record combineRecords(Record originalRecord,
 Record enrichmentRecord,
 RecordSchema resultSchema)

createResultSchema

protected abstract RecordSchema createResultSchema(Record firstOriginalRecord,
 Record firstEnrichmentRecord)