public class JdbcConnection extends CalciteConnectionWrapper
Implements and delegates to CalciteConnection
, adds Beam-specific helper methods.
BeamCalciteSchemas
keep reference to this connection. Pipeline options
are stored here.
Modifier and Type | Method and Description |
---|---|
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.SchemaPlus |
getCurrentSchemaPlus()
Calcite-created
SchemaPlus wrapper for the current schema. |
PipelineOptions |
getPipelineOptions() |
void |
setPipelineOptions(PipelineOptions pipelineOptions) |
void |
setPipelineOptionsMap(java.util.Map<java.lang.String,java.lang.String> pipelineOptionsMap)
Only called from the
BeamCalciteSchema . |
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
public void setPipelineOptionsMap(java.util.Map<java.lang.String,java.lang.String> pipelineOptionsMap)
BeamCalciteSchema
. This is needed to enable the `SET
pipelineOption = blah
` syntaxpublic void setPipelineOptions(PipelineOptions pipelineOptions)
public PipelineOptions getPipelineOptions()
public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.SchemaPlus getCurrentSchemaPlus()
SchemaPlus
wrapper for the current schema.