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

Class CalciteFactoryWrapper

java.lang.Object

org.apache.calcite.jdbc.CalciteFactory

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

All Implemented Interfaces:

org.apache.calcite.avatica.AvaticaFactory

public abstract class CalciteFactoryWrapper
extends 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 and Description
protected org.apache.calcite.jdbc.CalciteFactory	factory

Fields inherited from class org.apache.calcite.jdbc.CalciteFactory

major, minor

Method Summary

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

Methods inherited from class 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 Detail

factory

protected org.apache.calcite.jdbc.CalciteFactory factory

Method Detail

newConnection

public org.apache.calcite.avatica.AvaticaConnection newConnection(org.apache.calcite.avatica.UnregisteredDriver driver,
                                                                  org.apache.calcite.avatica.AvaticaFactory avaticaFactory,
                                                                  java.lang.String url,
                                                                  java.util.Properties info,
                                                                  org.apache.calcite.jdbc.CalciteSchema rootSchema,
                                                                  org.apache.calcite.adapter.java.JavaTypeFactory typeFactory)

Specified by:

newConnection in class org.apache.calcite.jdbc.CalciteFactory

newStatement

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

Throws:

java.sql.SQLException

newPreparedStatement

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

Throws:

java.sql.SQLException

newResultSet

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

Throws:

java.sql.SQLException

newDatabaseMetaData

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

newResultSetMetaData

public java.sql.ResultSetMetaData newResultSetMetaData(org.apache.calcite.avatica.AvaticaStatement statement,
                                                       org.apache.calcite.avatica.Meta.Signature signature)
                                                throws java.sql.SQLException

Throws:

java.sql.SQLException