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:

java.lang.AutoCloseable, java.sql.Connection, java.sql.Wrapper, org.apache.calcite.jdbc.CalciteConnection, 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 and Description
void	setPipelineOptionsMap(java.util.Map<java.lang.String,java.lang.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

Method Detail

setPipelineOptionsMap

public void setPipelineOptionsMap(java.util.Map<java.lang.String,java.lang.String> pipelineOptionsMap)

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