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

Class CalciteFactoryWrapper

  • All Implemented Interfaces:
    org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.AvaticaFactory
    public abstract class CalciteFactoryWrapper
extends org.apache.beam.vendor.calcite.v1_40_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_40_0.org.apache.calcite.jdbc.CalciteFactory factory  

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

        major, minor

    • Method Summary

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

      • Methods inherited from class org.apache.beam.vendor.calcite.v1_40_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 Detail

      • factory

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

    • Method Detail

      • newConnection

        public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.AvaticaConnection newConnection​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.UnregisteredDriver driver,
                                                                                                         org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.AvaticaFactory avaticaFactory,
                                                                                                         java.lang.String url,
                                                                                                         java.util.Properties info,
                                                                                                         @Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.jdbc.CalciteSchema rootSchema,
                                                                                                         @Nullable org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.adapter.java.JavaTypeFactory typeFactory)
        Specified by:
        newConnection in class org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.jdbc.CalciteFactory

      • newStatement

        public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.AvaticaStatement newStatement​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.AvaticaConnection connection,
                                                                                                       org.apache.beam.vendor.calcite.v1_40_0.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.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.AvaticaPreparedStatement newPreparedStatement​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.AvaticaConnection connection,
                                                                                                                       org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.Meta.StatementHandle h,
                                                                                                                       org.apache.beam.vendor.calcite.v1_40_0.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.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.AvaticaResultSet newResultSet​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.AvaticaStatement statement,
                                                                                                       org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.QueryState state,
                                                                                                       org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.Meta.Signature signature,
                                                                                                       java.util.TimeZone timeZone,
                                                                                                       org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.Meta.Frame firstFrame)
                                                                                                throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • newDatabaseMetaData

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

      • newResultSetMetaData

        public java.sql.ResultSetMetaData newResultSetMetaData​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.AvaticaStatement statement,
                                                       org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.avatica.Meta.Signature signature)
                                                throws java.sql.SQLException
        Throws:
        java.sql.SQLException