Package org.apache.calcite.jdbc
Class CalciteConnectionImpl.DataContextImpl
- java.lang.Object
-
- org.apache.calcite.jdbc.CalciteConnectionImpl.DataContextImpl
-
- All Implemented Interfaces:
DataContext
- Enclosing class:
- CalciteConnectionImpl
static class CalciteConnectionImpl.DataContextImpl extends java.lang.Object implements DataContext
Implementation of DataContext.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.calcite.DataContext
DataContext.Variable
-
-
Field Summary
Fields Modifier and Type Field Description private com.google.common.collect.ImmutableMap<java.lang.Object,java.lang.Object>
map
private QueryProvider
queryProvider
private CalciteSchema
rootSchema
private JavaTypeFactory
typeFactory
-
Fields inherited from interface org.apache.calcite.DataContext
ROOT
-
-
Constructor Summary
Constructors Constructor Description DataContextImpl(CalciteConnectionImpl connection, java.util.Map<java.lang.String,java.lang.Object> parameters, CalciteSchema rootSchema)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Object
get(java.lang.String name)
Returns a context variable.QueryProvider
getQueryProvider()
Returns the query provider.SchemaPlus
getRootSchema()
Returns a sub-schema with a given name, or null.private SqlAdvisor
getSqlAdvisor()
JavaTypeFactory
getTypeFactory()
Returns the type factory.
-
-
-
Field Detail
-
map
private final com.google.common.collect.ImmutableMap<java.lang.Object,java.lang.Object> map
-
rootSchema
private final CalciteSchema rootSchema
-
queryProvider
private final QueryProvider queryProvider
-
typeFactory
private final JavaTypeFactory typeFactory
-
-
Constructor Detail
-
DataContextImpl
DataContextImpl(CalciteConnectionImpl connection, java.util.Map<java.lang.String,java.lang.Object> parameters, CalciteSchema rootSchema)
-
-
Method Detail
-
get
public java.lang.Object get(java.lang.String name)
Description copied from interface:DataContext
Returns a context variable.Supported variables include: "sparkContext", "currentTimestamp", "localTimestamp".
- Specified by:
get
in interfaceDataContext
- Parameters:
name
- Name of variable
-
getSqlAdvisor
private SqlAdvisor getSqlAdvisor()
-
getRootSchema
public SchemaPlus getRootSchema()
Description copied from interface:DataContext
Returns a sub-schema with a given name, or null.- Specified by:
getRootSchema
in interfaceDataContext
-
getTypeFactory
public JavaTypeFactory getTypeFactory()
Description copied from interface:DataContext
Returns the type factory.- Specified by:
getTypeFactory
in interfaceDataContext
-
getQueryProvider
public QueryProvider getQueryProvider()
Description copied from interface:DataContext
Returns the query provider.- Specified by:
getQueryProvider
in interfaceDataContext
-
-