Class ArrowFlightJdbcFactory

java.lang.Object
org.apache.arrow.driver.jdbc.ArrowFlightJdbcFactory
All Implemented Interfaces:
org.apache.calcite.avatica.AvaticaFactory

public class ArrowFlightJdbcFactory extends Object implements org.apache.calcite.avatica.AvaticaFactory
Factory for the Arrow Flight JDBC Driver.
  • Constructor Details

    • ArrowFlightJdbcFactory

      public ArrowFlightJdbcFactory()
  • Method Details

    • newConnection

      public org.apache.calcite.avatica.AvaticaConnection newConnection(org.apache.calcite.avatica.UnregisteredDriver driver, org.apache.calcite.avatica.AvaticaFactory factory, String url, Properties info) throws SQLException
      Specified by:
      newConnection in interface org.apache.calcite.avatica.AvaticaFactory
      Throws:
      SQLException
    • newStatement

      public org.apache.calcite.avatica.AvaticaStatement newStatement(org.apache.calcite.avatica.AvaticaConnection connection, org.apache.calcite.avatica.Meta.StatementHandle handle, int resultType, int resultSetConcurrency, int resultSetHoldability)
      Specified by:
      newStatement in interface org.apache.calcite.avatica.AvaticaFactory
    • newPreparedStatement

      public ArrowFlightPreparedStatement newPreparedStatement(org.apache.calcite.avatica.AvaticaConnection connection, org.apache.calcite.avatica.Meta.StatementHandle statementHandle, org.apache.calcite.avatica.Meta.Signature signature, int resultType, int resultSetConcurrency, int resultSetHoldability) throws SQLException
      Specified by:
      newPreparedStatement in interface org.apache.calcite.avatica.AvaticaFactory
      Throws:
      SQLException
    • newResultSet

      public ArrowFlightJdbcVectorSchemaRootResultSet newResultSet(org.apache.calcite.avatica.AvaticaStatement statement, org.apache.calcite.avatica.QueryState state, org.apache.calcite.avatica.Meta.Signature signature, TimeZone timeZone, org.apache.calcite.avatica.Meta.Frame frame) throws SQLException
      Specified by:
      newResultSet in interface org.apache.calcite.avatica.AvaticaFactory
      Throws:
      SQLException
    • newDatabaseMetaData

      public org.apache.calcite.avatica.AvaticaSpecificDatabaseMetaData newDatabaseMetaData(org.apache.calcite.avatica.AvaticaConnection connection)
      Specified by:
      newDatabaseMetaData in interface org.apache.calcite.avatica.AvaticaFactory
    • newResultSetMetaData

      public ResultSetMetaData newResultSetMetaData(org.apache.calcite.avatica.AvaticaStatement avaticaStatement, org.apache.calcite.avatica.Meta.Signature signature)
      Specified by:
      newResultSetMetaData in interface org.apache.calcite.avatica.AvaticaFactory
    • getJdbcMajorVersion

      public int getJdbcMajorVersion()
      Specified by:
      getJdbcMajorVersion in interface org.apache.calcite.avatica.AvaticaFactory
    • getJdbcMinorVersion

      public int getJdbcMinorVersion()
      Specified by:
      getJdbcMinorVersion in interface org.apache.calcite.avatica.AvaticaFactory