Uses of Class
org.apache.nifi.processors.standard.enrichment.SqlJoinCalciteParameters

Packages that use SqlJoinCalciteParameters

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

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

Fields in org.apache.nifi.processors.standard.enrichment with type parameters of type SqlJoinCalciteParameters

Modifier and Type	Field	Description
private final com.github.benmanes.caffeine.cache.Cache<Tuple<String,RecordSchema>,BlockingQueue<SqlJoinCalciteParameters>>	SqlJoinCache.calciteParameterQueues

Methods in org.apache.nifi.processors.standard.enrichment that return SqlJoinCalciteParameters

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)

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

Modifier and Type	Method	Description
void	SqlJoinCache.returnCalciteParameters(String sql, RecordSchema schema, SqlJoinCalciteParameters parameters)

Method parameters in org.apache.nifi.processors.standard.enrichment with type arguments of type SqlJoinCalciteParameters

Modifier and Type	Method	Description
private void	SqlJoinCache.clearQueue(BlockingQueue<SqlJoinCalciteParameters> parameterQueue)
private void	SqlJoinCache.onCacheEviction(Tuple<String,RecordSchema> key, BlockingQueue<SqlJoinCalciteParameters> queue, com.github.benmanes.caffeine.cache.RemovalCause cause)