Package org.apache.beam.sdk.extensions.sql.impl

Class CalciteFactoryWrapper

java.lang.Object

org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.jdbc.CalciteFactory

org.apache.beam.sdk.extensions.sql.impl.CalciteFactoryWrapper

All Implemented Interfaces:

org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaFactory

public abstract class CalciteFactoryWrapper
extends org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.jdbc.CalciteFactory

Wrapper for CalciteFactory.

This is a non-functional class to delegate to the underlying CalciteFactory. The purpose is to hide the delegation logic from the implementation (JdbcFactory).

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.jdbc.CalciteFactory	factory

Fields inherited from class org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.jdbc.CalciteFactory

major, minor

Method Summary

Modifier and Type	Method	Description
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaConnection	newConnection(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.UnregisteredDriver driver, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaFactory avaticaFactory, String url, Properties info, @Nullable org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.jdbc.CalciteSchema rootSchema, @Nullable org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.adapter.java.JavaTypeFactory typeFactory)
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaSpecificDatabaseMetaData	newDatabaseMetaData(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaConnection connection)
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaPreparedStatement	newPreparedStatement(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaConnection connection, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.Meta.StatementHandle h, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.Meta.Signature signature, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaResultSet	newResultSet(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaStatement statement, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.QueryState state, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.Meta.Signature signature, TimeZone timeZone, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.Meta.Frame firstFrame)
ResultSetMetaData	newResultSetMetaData(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaStatement statement, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.Meta.Signature signature)
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaStatement	newStatement(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaConnection connection, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.Meta.StatementHandle h, int resultSetType, int resultSetConcurrency, int resultSetHoldability)

Methods inherited from class org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.jdbc.CalciteFactory

getJdbcMajorVersion, getJdbcMinorVersion, newConnection

Methods inherited from class java.lang.Object

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

Field Details

factory

protected org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.jdbc.CalciteFactory factory

Method Details

newConnection

public org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaConnection newConnection(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.UnregisteredDriver driver,
 org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaFactory avaticaFactory,
 String url,
 Properties info,
 @Nullable org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.jdbc.CalciteSchema rootSchema,
 @Nullable org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.adapter.java.JavaTypeFactory typeFactory)

Specified by:

newConnection in class org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.jdbc.CalciteFactory

newStatement

public org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaStatement newStatement(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaConnection connection,
 org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.Meta.StatementHandle h,
 int resultSetType,
 int resultSetConcurrency,
 int resultSetHoldability)
                                                                                                throws SQLException

Throws:

SQLException

newPreparedStatement

public org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaPreparedStatement newPreparedStatement(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaConnection connection,
 org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.Meta.StatementHandle h,
 org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.Meta.Signature signature,
 int resultSetType,
 int resultSetConcurrency,
 int resultSetHoldability)
                                                                                                                throws SQLException

Throws:

SQLException

newResultSet

public org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaResultSet newResultSet(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaStatement statement,
 org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.QueryState state,
 org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.Meta.Signature signature,
 TimeZone timeZone,
 org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.Meta.Frame firstFrame)
                                                                                                throws SQLException

Throws:

SQLException

newDatabaseMetaData

public org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaSpecificDatabaseMetaData newDatabaseMetaData(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaConnection connection)

newResultSetMetaData

public ResultSetMetaData newResultSetMetaData(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.AvaticaStatement statement,
 org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.avatica.Meta.Signature signature)
                                       throws SQLException

Throws:

SQLException