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

Class SqlJoinCache

java.lang.Object

org.apache.nifi.processors.standard.enrichment.SqlJoinCache

All Implemented Interfaces:

AutoCloseable

public class SqlJoinCache
extends Object
implements AutoCloseable

Field Summary

Fields

Modifier and Type	Field	Description
private final com.github.benmanes.caffeine.cache.Cache<Tuple<String,RecordSchema>,BlockingQueue<SqlJoinCalciteParameters>>	calciteParameterQueues
private final org.apache.nifi.logging.ComponentLog	logger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
private void	clearQueue(BlockingQueue<SqlJoinCalciteParameters> parameterQueue)
void	close()
private SqlJoinCalciteParameters	createCalciteParameters(String sql, RecordJoinInput originalInput, RecordJoinInput enrichmentInput)
SqlJoinCalciteParameters	getCalciteParameters(String sql, RecordSchema schema, RecordJoinInput originalInput, RecordJoinInput enrichmentInput)
private void	onCacheEviction(Tuple<String,RecordSchema> key, BlockingQueue<SqlJoinCalciteParameters> queue, com.github.benmanes.caffeine.cache.RemovalCause cause)
void	returnCalciteParameters(String sql, RecordSchema schema, SqlJoinCalciteParameters parameters)

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

calciteParameterQueues

private final com.github.benmanes.caffeine.cache.Cache<Tuple<String,RecordSchema>,BlockingQueue<SqlJoinCalciteParameters>> calciteParameterQueues

Constructor Details

SqlJoinCache

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

Method Details

getCalciteParameters

public SqlJoinCalciteParameters getCalciteParameters(String sql,
 RecordSchema schema,
 RecordJoinInput originalInput,
 RecordJoinInput enrichmentInput)
                                              throws SQLException

Throws:

SQLException

returnCalciteParameters

public void returnCalciteParameters(String sql,
 RecordSchema schema,
 SqlJoinCalciteParameters parameters)

createCalciteParameters

private SqlJoinCalciteParameters createCalciteParameters(String sql,
 RecordJoinInput originalInput,
 RecordJoinInput enrichmentInput)
                                                  throws SQLException

Throws:

SQLException

onCacheEviction

private void onCacheEviction(Tuple<String,RecordSchema> key,
 BlockingQueue<SqlJoinCalciteParameters> queue,
 com.github.benmanes.caffeine.cache.RemovalCause cause)

clearQueue

private void clearQueue(BlockingQueue<SqlJoinCalciteParameters> parameterQueue)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception