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

Class JdbcConnection

java.lang.Object

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

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

All Implemented Interfaces:

AutoCloseable, Connection, Wrapper, org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.jdbc.CalciteConnection, org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.linq4j.QueryProvider

public class JdbcConnection
extends CalciteConnectionWrapper

Beam JDBC Connection.

Implements and delegates to CalciteConnection, adds Beam-specific helper methods. BeamCalciteSchemas keep reference to this connection. Pipeline options are stored here.

Field Summary

Fields inherited from interface java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Method Summary

Modifier and Type	Method	Description
org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.SchemaPlus	getCurrentSchemaPlus()	Calcite-created SchemaPlus wrapper for the current schema.
org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.util.ListSqlOperatorTable	getExtraOperatorTable()	The session-scoped, mutable operator table chained at the front of the planner's operator table.
@Nullable PipelineOptions	getPipelineOptions()
void	setPipelineOptions(PipelineOptions pipelineOptions)
void	setPipelineOptionsMap(Map<String,String> pipelineOptionsMap)	Only called from the BeamCalciteSchema.

Methods inherited from class org.apache.beam.sdk.extensions.sql.impl.CalciteConnectionWrapper

abort, clearWarnings, close, commit, config, connection, createArrayOf, createBlob, createClob, createNClob, createPrepareContext, createQuery, createQuery, createSQLXML, createStatement, createStatement, createStatement, createStruct, execute, execute, executeQuery, getAutoCommit, getCatalog, getClientInfo, getClientInfo, getHoldability, getMetaData, getNetworkTimeout, getProperties, getRootSchema, getSchema, getTransactionIsolation, getTypeFactory, getTypeMap, getWarnings, isClosed, isReadOnly, isValid, isWrapperFor, nativeSQL, prepareCall, prepareCall, prepareCall, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, releaseSavepoint, rollback, rollback, setAutoCommit, setCatalog, setClientInfo, setClientInfo, setHoldability, setNetworkTimeout, setReadOnly, setSavepoint, setSavepoint, setSchema, setTransactionIsolation, setTypeMap, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.sql.Connection

beginRequest, endRequest, setShardingKey, setShardingKey, setShardingKeyIfValid, setShardingKeyIfValid

Method Details

getExtraOperatorTable

public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.sql.util.ListSqlOperatorTable getExtraOperatorTable()

The session-scoped, mutable operator table chained at the front of the planner's operator table. Add custom SqlOperators here to make them resolvable in subsequent SQL.

setPipelineOptionsMap

public void setPipelineOptionsMap(Map<String,String> pipelineOptionsMap)

Only called from the BeamCalciteSchema. This is needed to enable the `SET pipelineOption = blah` syntax

setPipelineOptions

public void setPipelineOptions(PipelineOptions pipelineOptions)

getPipelineOptions

public @Nullable PipelineOptions getPipelineOptions()

getCurrentSchemaPlus

public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.SchemaPlus getCurrentSchemaPlus()

Calcite-created SchemaPlus wrapper for the current schema.