Package org.apache.calcite.adapter.jdbc

Class JdbcCorrelationDataContext

java.lang.Object

org.apache.calcite.adapter.jdbc.JdbcCorrelationDataContext

All Implemented Interfaces:

DataContext

public class JdbcCorrelationDataContext
extends Object
implements DataContext

A special DataContext which handles correlation variable for batch nested loop joins.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.calcite.DataContext

DataContext.Variable

Field Summary

Fields

Modifier and Type	Field	Description
static final int	OFFSET

Fields inherited from interface org.apache.calcite.DataContext

ROOT

Constructor Summary

Constructors

Constructor	Description
JdbcCorrelationDataContext(DataContext delegate, Object[] parameters)

Method Summary

Modifier and Type	Method	Description
@Nullable Object	get(String name)	Returns a context variable.
QueryProvider	getQueryProvider()	Returns the query provider.
@Nullable SchemaPlus	getRootSchema()	Returns a sub-schema with a given name, or null.
JavaTypeFactory	getTypeFactory()	Returns the type factory.

Methods inherited from class java.lang.Object

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

Field Details

OFFSET

public static final int OFFSET

See Also:

• Constant Field Values

Constructor Details

JdbcCorrelationDataContext

public JdbcCorrelationDataContext(DataContext delegate,
 Object[] parameters)

Method Details

getRootSchema

public @Nullable SchemaPlus getRootSchema()

Description copied from interface: DataContext

Returns a sub-schema with a given name, or null.

Specified by:

getRootSchema in interface DataContext

getTypeFactory

public JavaTypeFactory getTypeFactory()

Description copied from interface: DataContext

Returns the type factory.

Specified by:

getTypeFactory in interface DataContext

getQueryProvider

public QueryProvider getQueryProvider()

Description copied from interface: DataContext

Returns the query provider.

Specified by:

getQueryProvider in interface DataContext

get

public @Nullable Object get(String name)

Description copied from interface: DataContext

Returns a context variable.

Supported variables include: "sparkContext", "currentTimestamp", "localTimestamp".

Specified by:

get in interface DataContext

Parameters:

name - Name of variable