Package org.apache.calcite.jdbc

Interface CalcitePrepare

All Known Implementing Classes:

CalcitePrepareImpl

public interface CalcitePrepare

API for a service that prepares statements for execution.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	CalcitePrepare.AnalyzeViewResult	The result of analyzing a view.
static class	CalcitePrepare.CalciteSignature<T>	The result of preparing a query.
static interface	CalcitePrepare.Context	Context for preparing a statement.
static class	CalcitePrepare.ConvertResult	The result of parsing and validating a SQL query and converting it to relational algebra.
static class	CalcitePrepare.Dummy	Namespace that allows us to define non-abstract methods inside an interface.
static class	CalcitePrepare.ParseResult	The result of parsing and validating a SQL query.
static class	CalcitePrepare.Query<T>	A union type of the three possible ways of expressing a query: as a SQL string, a Queryable or a RelNode.
static interface	CalcitePrepare.SparkHandler	Callback to register Spark as the main engine.

Field Summary

Fields

Modifier and Type	Field	Description
static final Function0<CalcitePrepare>	DEFAULT_FACTORY
static final ThreadLocal<@Nullable Deque<CalcitePrepare.Context>>	THREAD_CONTEXT_STACK

Method Summary

Modifier and Type	Method	Description
CalcitePrepare.AnalyzeViewResult	analyzeView(CalcitePrepare.Context context, String sql, boolean fail)	Analyzes a view.
CalcitePrepare.ConvertResult	convert(CalcitePrepare.Context context, String sql)
void	executeDdl(CalcitePrepare.Context context, SqlNode node)	Executes a DDL statement.
CalcitePrepare.ParseResult	parse(CalcitePrepare.Context context, String sql)
<T> CalcitePrepare.CalciteSignature<T>	prepareQueryable(CalcitePrepare.Context context, Queryable<T> queryable)
<T> CalcitePrepare.CalciteSignature<T>	prepareSql(CalcitePrepare.Context context, CalcitePrepare.Query<T> query, Type elementType, long maxRowCount)

Field Details

DEFAULT_FACTORY

static final Function0<CalcitePrepare> DEFAULT_FACTORY

THREAD_CONTEXT_STACK

static final ThreadLocal<@Nullable Deque<CalcitePrepare.Context>> THREAD_CONTEXT_STACK

Method Details

parse

CalcitePrepare.ParseResult parse(CalcitePrepare.Context context,
 String sql)

convert

CalcitePrepare.ConvertResult convert(CalcitePrepare.Context context,
 String sql)

executeDdl

void executeDdl(CalcitePrepare.Context context,
 SqlNode node)

Executes a DDL statement.

The statement identified itself as DDL in the CalcitePrepare.ParseResult.kind() field.

analyzeView

CalcitePrepare.AnalyzeViewResult analyzeView(CalcitePrepare.Context context,
 String sql,
 boolean fail)

Analyzes a view.

Parameters:

context - Context

sql - View SQL

fail - Whether to fail (and throw a descriptive error message) if the view is not modifiable

Returns:

Result of analyzing the view

prepareSql

<T> CalcitePrepare.CalciteSignature<T> prepareSql(CalcitePrepare.Context context,
 CalcitePrepare.Query<T> query,
 Type elementType,
 long maxRowCount)

prepareQueryable

<T> CalcitePrepare.CalciteSignature<T> prepareQueryable(CalcitePrepare.Context context,
 Queryable<T> queryable)