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

Class SqlJoinCalciteParameters

java.lang.Object

org.apache.nifi.processors.standard.enrichment.SqlJoinCalciteParameters

All Implemented Interfaces:

AutoCloseable

public class SqlJoinCalciteParameters
extends Object
implements AutoCloseable

Field Summary

Fields

Modifier and Type	Field	Description
private final CalciteDatabase	database
private static final org.slf4j.Logger	logger
private final PreparedStatement	preparedStatement
private final String	sql

Constructor Summary

Constructors

Constructor	Description
SqlJoinCalciteParameters(String sql, CalciteDatabase database, PreparedStatement preparedStatement)

Method Summary

Modifier and Type	Method	Description
void	close()
private void	closeQuietly(AutoCloseable closeable, String description)
CalciteDatabase	getDatabase()
PreparedStatement	getPreparedStatement()
String	getSql()

Methods inherited from class java.lang.Object

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

Field Details

logger

private static final org.slf4j.Logger logger

sql

private final String sql

database

private final CalciteDatabase database

preparedStatement

private final PreparedStatement preparedStatement

Constructor Details

SqlJoinCalciteParameters

public SqlJoinCalciteParameters(String sql,
 CalciteDatabase database,
 PreparedStatement preparedStatement)

Method Details

getSql

public String getSql()

getDatabase

public CalciteDatabase getDatabase()

getPreparedStatement

public PreparedStatement getPreparedStatement()

close

public void close()

Specified by:

close in interface AutoCloseable

closeQuietly

private void closeQuietly(AutoCloseable closeable,
 String description)