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

Interface RecordJoinStrategy

All Known Implementing Classes:

IndexCorrelatedJoinStrategy, InsertRecordFieldsJoinStrategy, SqlJoinStrategy, WrapperJoinStrategy

public interface RecordJoinStrategy

Method Summary

Modifier and Type	Method	Description
RecordJoinResult	join(RecordJoinInput originalInput, RecordJoinInput enrichmentInput, Map<String,String> combinedAttributes, org.apache.nifi.processor.ProcessSession session, RecordSchema outputSchema)

Method Details

join

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

Throws:

Exception