Uses of Class org.apache.nifi.processors.standard.enrichment.RecordJoinInput (nifi-standard-processors 2.6.0 API)

Packages that use RecordJoinInput

Package

Description

org.apache.nifi.processors.standard.enrichment

Uses of RecordJoinInput in org.apache.nifi.processors.standard.enrichment

Methods in org.apache.nifi.processors.standard.enrichment with parameters of type RecordJoinInput

Modifier and Type

Method

Description

private SqlJoinCalciteParameters

SqlJoinCache.createCalciteParameters(String sql, RecordJoinInput originalInput, RecordJoinInput enrichmentInput)

SqlJoinCalciteParameters

SqlJoinCache.getCalciteParameters(String sql, RecordSchema schema, RecordJoinInput originalInput, RecordJoinInput enrichmentInput)

RecordJoinResult

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

RecordJoinResult

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

RecordJoinResult

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