A C D E F G H I J L M N O P Q R S T U V

A

accept(QueryOperationVisitor<T>) - Method in class org.apache.flink.table.operations.PlannerQueryOperation

addToSelectList(List<SqlNode>, Set<String>, List<Map.Entry<String, RelDataType>>, SqlNode, SqlValidatorScope, boolean) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Adds an expression to a select list, ensuring that its alias does not clash with any existing expressions on the list.

apply(List<Transformation<?>>) - Method in class org.apache.flink.table.executor.StreamExecutor

apply(Join, JoinRelType, RexNode) - Method in interface org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule.Predicate

asRootSchema(Schema) - Static method in class org.apache.calcite.jdbc.CalciteSchemaBuilder

Creates a CalciteSchema with a given Schema as the root.

asSummaryString() - Method in class org.apache.flink.table.operations.PlannerQueryOperation

AuxiliaryConverter - Interface in org.apache.calcite.sql2rel

Converts an expression for a group window function (e.g.

AuxiliaryConverter.Impl - Class in org.apache.calcite.sql2rel

Simple implementation of AuxiliaryConverter.

C

CalciteParser - Class in org.apache.flink.table.calcite

Thin wrapper around SqlParser that does exception conversion and SqlNode casting.

CalciteParser(SqlParser.Config) - Constructor for class org.apache.flink.table.calcite.CalciteParser

CalciteSchemaBuilder - Class in org.apache.calcite.jdbc

This class is used to create a CalciteSchema with a given Schema as the root.

CatalogCalciteSchema - Class in org.apache.flink.table.catalog

A mapping between Flink's catalog and Calcite's schema.

CatalogCalciteSchema(boolean, String, CatalogManager) - Constructor for class org.apache.flink.table.catalog.CatalogCalciteSchema

CatalogManagerCalciteSchema - Class in org.apache.flink.table.catalog

Bridge between the CatalogManager and the Schema.

CatalogManagerCalciteSchema(CatalogManager, boolean) - Constructor for class org.apache.flink.table.catalog.CatalogManagerCalciteSchema

CatalogReader - Class in org.apache.flink.table.catalog

A thin wrapper around CalciteCatalogReader that enables providing multiple default paths to look in.

CatalogReader(CalciteSchema, List<List<String>>, RelDataTypeFactory, CalciteConnectionConfig) - Constructor for class org.apache.flink.table.catalog.CatalogReader

checkTypeAssignment(RelDataType, RelDataType, SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

columnListParamToParentCursorMap - Variable in class org.apache.calcite.sql.validate.SqlValidatorImpl.FunctionParamInfo

Maps a column list parameter to the parent cursor parameter it references.

convert(RexBuilder, RexNode, RexNode) - Method in interface org.apache.calcite.sql2rel.AuxiliaryConverter

Converts an expression.

convert(RexBuilder, RexNode, RexNode) - Method in class org.apache.calcite.sql2rel.AuxiliaryConverter.Impl

convert(FlinkPlannerImpl, CatalogManager, SqlNode) - Static method in class org.apache.flink.table.sqlexec.SqlToOperationConverter

This is the main entrance for executing all kinds of DDL/DML SqlNodes, different SqlNode will have it's implementation in the #convert(type) method whose 'type' argument is subclass of SqlNode.

create(RelOptPlanner, RexBuilder) - Static method in class org.apache.calcite.plan.RelOptCluster

Creates a cluster.

create(Map<String, String>, StreamExecutionEnvironment) - Method in class org.apache.flink.table.executor.StreamExecutorFactory

Creates a corresponding StreamExecutor.

create(Map<String, String>) - Method in class org.apache.flink.table.executor.StreamExecutorFactory

create(Map<String, String>, Executor, TableConfig, FunctionCatalog, CatalogManager) - Method in class org.apache.flink.table.planner.StreamPlannerFactory

createCalciteParser() - Method in class org.apache.flink.table.planner.PlanningConfigurationBuilder

Creates a configured instance of CalciteParser.

createCalciteTable(QueryOperationCatalogView) - Static method in class org.apache.flink.table.catalog.QueryOperationCatalogViewTable

createCorrel() - Method in class org.apache.calcite.plan.RelOptCluster

Constructs a new id for a correlating variable.

createFlinkPlanner(String, String) - Method in class org.apache.flink.table.planner.PlanningConfigurationBuilder

Creates a configured FlinkPlannerImpl for a planning session.

createMatchRecognizeNameSpace(SqlMatchRecognize, SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

createOuterSerializerWithNestedSerializers(TypeSerializer<?>[]) - Method in class org.apache.flink.table.runtime.types.CRowSerializerSnapshot

createRelBuilder(String, String) - Method in class org.apache.flink.table.planner.PlanningConfigurationBuilder

Creates a configured FlinkRelBuilder for a planning session.

createSelectNamespace(SqlSelect, SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Creates a namespace for a SELECT node.

createSetopNamespace(SqlCall, SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Creates a namespace for a set operation (UNION, INTERSECT, or EXCEPT).

createSourceSelectForDelete(SqlDelete) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Creates the SELECT statement that putatively feeds rows into a DELETE statement to be deleted.

createSourceSelectForUpdate(SqlUpdate) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Creates the SELECT statement that putatively feeds rows into an UPDATE statement to be updated.

createTargetRowType(SqlValidatorTable, SqlNodeList, boolean) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Derives a row-type for INSERT and UPDATE operations.

CRowSerializerSnapshot - Class in org.apache.flink.table.runtime.types

Snapshot class for CRowSerializer.

CRowSerializerSnapshot() - Constructor for class org.apache.flink.table.runtime.types.CRowSerializerSnapshot

Constructor for read instantiation.

CRowSerializerSnapshot(CRowSerializer) - Constructor for class org.apache.flink.table.runtime.types.CRowSerializerSnapshot

Constructor to create the snapshot for writing.

cursorPosToSelectMap - Variable in class org.apache.calcite.sql.validate.SqlValidatorImpl.FunctionParamInfo

Maps a cursor (based on its position relative to other cursor parameters within a function call) to the SELECT associated with the cursor.

D

declareCursor(SqlSelect, SqlValidatorScope) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

defaultMethod(QueryOperation) - Method in class org.apache.flink.table.plan.QueryOperationConverter

deriveAlias(SqlNode, int) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

deriveConstructorType(SqlValidatorScope, SqlCall, SqlFunction, SqlFunction, List<RelDataType>) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

deriveType(SqlValidator, SqlValidatorScope, SqlCall) - Method in class org.apache.calcite.sql.SqlFunction

deriveType(SqlValidatorScope, SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

DmlNamespace(SqlValidatorImpl, SqlNode, SqlNode, SqlValidatorScope) - Constructor for class org.apache.calcite.sql.validate.SqlValidatorImpl.DmlNamespace

DUMB_FILTER_ON_JOIN - Static variable in class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule

Dumber version of FlinkFilterJoinRule.FILTER_ON_JOIN.

E

execute(String) - Method in class org.apache.flink.table.executor.StreamExecutor

expand(SqlNode, SqlValidatorScope) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

expandColumnReferences - Variable in class org.apache.calcite.sql.validate.SqlValidatorImpl

expandGroupByOrHavingExpr(SqlNode, SqlValidatorScope, SqlSelect, boolean) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

expandIdentifiers - Variable in class org.apache.calcite.sql.validate.SqlValidatorImpl

expandOrderExpr(SqlSelect, SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

expandStar(SqlNodeList, SqlSelect, boolean) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

ExtendedAggregateExtractProjectRule - Class in org.apache.flink.table.plan.rules.logical

Rule to extract a Project from a LogicalAggregate, a LogicalWindowAggregate or a TableAggregate and push it down towards the input.

ExtendedAggregateExtractProjectRule(RelOptRuleOperand, RelBuilderFactory) - Constructor for class org.apache.flink.table.plan.rules.logical.ExtendedAggregateExtractProjectRule

F

FILTER_ON_JOIN - Static variable in class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule

Rule that pushes predicates from a Filter into the Join below them.

FlinkFilterIntoJoinRule(boolean, RelBuilderFactory, FlinkFilterJoinRule.Predicate) - Constructor for class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule.FlinkFilterIntoJoinRule

FlinkFilterIntoJoinRule(boolean, RelFactories.FilterFactory, RelFactories.ProjectFactory, FlinkFilterJoinRule.Predicate) - Constructor for class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule.FlinkFilterIntoJoinRule

Deprecated.

FlinkFilterJoinRule - Class in org.apache.flink.table.plan.rules.logical

Planner rule that pushes filters above and within a join node into the join node and/or its children nodes.

FlinkFilterJoinRule(RelOptRuleOperand, String, boolean, RelBuilderFactory, FlinkFilterJoinRule.Predicate) - Constructor for class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule

Creates a FilterProjectTransposeRule with an explicit root operand and factories.

FlinkFilterJoinRule(RelOptRuleOperand, String, boolean, RelFactories.FilterFactory, RelFactories.ProjectFactory) - Constructor for class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule

Deprecated.

FlinkFilterJoinRule(RelOptRuleOperand, String, boolean, RelFactories.FilterFactory, RelFactories.ProjectFactory, FlinkFilterJoinRule.Predicate) - Constructor for class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule

Deprecated.

FlinkFilterJoinRule.FlinkFilterIntoJoinRule - Class in org.apache.flink.table.plan.rules.logical

Rule that tries to push filter expressions into a join condition and into the inputs of the join.

FlinkFilterJoinRule.FlinkJoinConditionPushRule - Class in org.apache.flink.table.plan.rules.logical

Rule that pushes parts of the join condition to its inputs.

FlinkFilterJoinRule.Predicate - Interface in org.apache.flink.table.plan.rules.logical

Predicate that returns whether a filter is valid in the ON clause of a join for this particular kind of join.

FlinkJoinConditionPushRule(RelBuilderFactory, FlinkFilterJoinRule.Predicate) - Constructor for class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule.FlinkJoinConditionPushRule

FlinkJoinConditionPushRule(RelFactories.FilterFactory, RelFactories.ProjectFactory, FlinkFilterJoinRule.Predicate) - Constructor for class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule.FlinkJoinConditionPushRule

Deprecated.

fullyQualify(SqlIdentifier) - Method in class org.apache.calcite.sql.validate.ParameterScope

functionCallStack - Variable in class org.apache.calcite.sql.validate.SqlValidatorImpl

Stack of objects that maintain information about function calls.

FunctionCatalogOperatorTable - Class in org.apache.flink.table.catalog

Thin adapter between SqlOperatorTable and FunctionCatalog.

FunctionCatalogOperatorTable(FunctionCatalog, FlinkTypeFactory) - Constructor for class org.apache.flink.table.catalog.FunctionCatalogOperatorTable

FunctionParamInfo() - Constructor for class org.apache.calcite.sql.validate.SqlValidatorImpl.FunctionParamInfo

G

getAggregate(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Returns the parse tree node (GROUP BY, HAVING, or an aggregate function call) that causes select to be an aggregate query, or null if it is not an aggregate query.

getCalciteTree() - Method in class org.apache.flink.table.operations.PlannerQueryOperation

getCatalogReader() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getChildren() - Method in class org.apache.flink.table.operations.PlannerQueryOperation

getColumnReferenceExpansion() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getCompilerHints() - Method in class org.apache.flink.table.explain.Node

getConformance() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getContents() - Method in class org.apache.flink.table.explain.Node

getContext() - Method in class org.apache.flink.table.planner.PlanningConfigurationBuilder

getCosts() - Method in class org.apache.flink.table.explain.Node

getCurrentOuterSnapshotVersion() - Method in class org.apache.flink.table.runtime.types.CRowSerializerSnapshot

getCursorScope(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getDefaultNullCollation() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getDriverStrategy() - Method in class org.apache.flink.table.explain.Node

getEmptyScope() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getEstimates() - Method in class org.apache.flink.table.explain.Node

getExecutionEnvironment() - Method in class org.apache.flink.table.executor.StreamExecutor

getExpression(SchemaPlus, String) - Method in class org.apache.flink.table.catalog.CatalogCalciteSchema

getExpression(SchemaPlus, String) - Method in class org.apache.flink.table.catalog.CatalogManagerCalciteSchema

getFieldOrigins(SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getFromScope(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getFunctionNames() - Method in class org.apache.flink.table.catalog.CatalogCalciteSchema

getFunctionNames() - Method in class org.apache.flink.table.catalog.CatalogManagerCalciteSchema

getFunctions(String) - Method in class org.apache.flink.table.catalog.CatalogCalciteSchema

getFunctions(String) - Method in class org.apache.flink.table.catalog.CatalogManagerCalciteSchema

getFunctionType() - Method in class org.apache.calcite.sql.SqlFunction

getGlobalProperties() - Method in class org.apache.flink.table.explain.Node

getGroupScope(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getHavingScope(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getId() - Method in class org.apache.flink.table.explain.Node

getJoinScope(SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getLocalProperties() - Method in class org.apache.flink.table.explain.Node

getLogicalSourceRowType(RelDataType, SqlInsert) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getLogicalTargetRowType(RelDataType, SqlInsert) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getMatchRecognizeScope(SqlMatchRecognize) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getMetadataFactory() - Method in class org.apache.calcite.plan.RelOptCluster

getMetadataProvider() - Method in class org.apache.calcite.plan.RelOptCluster

getMetadataQuery() - Method in class org.apache.calcite.plan.RelOptCluster

Returns the current RelMetadataQuery.

getNameAsId() - Method in class org.apache.calcite.sql.SqlFunction

getNamespace(SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getNestedSerializers(CRowSerializer) - Method in class org.apache.flink.table.runtime.types.CRowSerializerSnapshot

getOperandScope(SqlCall) - Method in class org.apache.calcite.sql.validate.ParameterScope

getOperatorList() - Method in class org.apache.flink.table.catalog.FunctionCatalogOperatorTable

getOperatorTable() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getOrderScope(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getOriginal(SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getOriginalExpression() - Method in class org.apache.calcite.plan.RelOptCluster

Deprecated.

getOverScope(SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getPact() - Method in class org.apache.flink.table.explain.Node

getParallelism() - Method in class org.apache.flink.table.explain.Node

getParameterRowType(SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getParamNames() - Method in class org.apache.calcite.sql.SqlFunction

Returns a list of parameter names.

getParamTypes() - Method in class org.apache.calcite.sql.SqlFunction

getParentCursor(String) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getPlanner() - Method in class org.apache.calcite.plan.RelOptCluster

getPlanner() - Method in class org.apache.flink.table.planner.PlanningConfigurationBuilder

Returns the Calcite RelOptPlanner that will be used.

getPredecessors() - Method in class org.apache.flink.table.explain.Node

getQuery() - Method in class org.apache.calcite.plan.RelOptCluster

Deprecated.

getRawSelectScope(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getRexBuilder() - Method in class org.apache.calcite.plan.RelOptCluster

getRowType(RelDataTypeFactory) - Method in class org.apache.flink.table.catalog.QueryOperationCatalogViewTable

getSelectScope(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getSelfJoinExprForUpdate(SqlNode, String) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Allows a subclass to provide information about how to convert an UPDATE into a MERGE via self-join.

getSqlExecutionPlan(String, Boolean) - Static method in class org.apache.flink.table.explain.PlanJsonParser

getSqlIdentifier() - Method in class org.apache.calcite.sql.SqlFunction

getSqlParserConfig() - Method in class org.apache.flink.table.planner.PlanningConfigurationBuilder

Returns the SQL parser config for this environment including a custom Calcite configuration.

getSubSchema(String) - Method in class org.apache.flink.table.catalog.CatalogCalciteSchema

Look up a sub-schema (database) by the given sub-schema name.

getSubSchema(String) - Method in class org.apache.flink.table.catalog.CatalogManagerCalciteSchema

getSubSchemaNames() - Method in class org.apache.flink.table.catalog.CatalogCalciteSchema

getSubSchemaNames() - Method in class org.apache.flink.table.catalog.CatalogManagerCalciteSchema

getSyntax() - Method in class org.apache.calcite.sql.SqlFunction

getTable(String) - Method in class org.apache.flink.table.catalog.CatalogCalciteSchema

getTable(String) - Method in class org.apache.flink.table.catalog.CatalogManagerCalciteSchema

getTableNames() - Method in class org.apache.flink.table.catalog.CatalogCalciteSchema

getTableNames() - Method in class org.apache.flink.table.catalog.CatalogManagerCalciteSchema

getTableSchema() - Method in class org.apache.flink.table.operations.PlannerQueryOperation

getType(String) - Method in class org.apache.flink.table.catalog.CatalogCalciteSchema

getType(String) - Method in class org.apache.flink.table.catalog.CatalogManagerCalciteSchema

getType() - Method in class org.apache.flink.table.explain.Node

getTypeCoercion() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getTypeFactory() - Method in class org.apache.calcite.plan.RelOptCluster

getTypeFactory() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getTypeFactory() - Method in class org.apache.flink.table.planner.PlanningConfigurationBuilder

Returns the FlinkTypeFactory that will be used.

getTypeNames() - Method in class org.apache.flink.table.catalog.CatalogCalciteSchema

getTypeNames() - Method in class org.apache.flink.table.catalog.CatalogManagerCalciteSchema

getUnknownType() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getValidatedNodeType(SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getValidatedNodeTypeIfKnown(SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getValidationErrorFunction() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getWhereScope(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getWindowByName(SqlIdentifier, SqlValidatorScope) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

getWithScope(SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

H

handleUnresolvedFunction(SqlCall, SqlFunction, List<RelDataType>, List<String>) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

I

id - Variable in class org.apache.calcite.sql.validate.SqlValidatorImpl.IdInfo

IdInfo(SqlValidatorScope, SqlIdentifier) - Constructor for class org.apache.calcite.sql.validate.SqlValidatorImpl.IdInfo

idPositions - Variable in class org.apache.calcite.sql.validate.SqlValidatorImpl

Maps ParsePosition strings to the SqlIdentifier identifier objects at these positions

Impl(SqlFunction) - Constructor for class org.apache.calcite.sql2rel.AuxiliaryConverter.Impl

inferUnknownTypes(RelDataType, SqlValidatorScope, SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

INSTANCE - Static variable in class org.apache.flink.table.expressions.PlannerTypeInferenceUtilImpl

INSTANCE - Static variable in class org.apache.flink.table.plan.rules.logical.ExtendedAggregateExtractProjectRule

invalidateMetadataQuery() - Method in class org.apache.calcite.plan.RelOptCluster

Should be called whenever the current RelMetadataQuery becomes invalid.

isAggregate(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

isAggregate(SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

isMutable() - Method in class org.apache.flink.table.catalog.CatalogCalciteSchema

isMutable() - Method in class org.apache.flink.table.catalog.CatalogManagerCalciteSchema

isNestedAggregateWindow(SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

isOverAggregateWindow(SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

isQuantifierAllowed() - Method in class org.apache.calcite.sql.SqlFunction

Returns whether this function allows a DISTINCT or ALL quantifier.

isSystemField(RelDataTypeField) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

isTypeCoercionEnabled() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

J

JOIN - Static variable in class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule

Rule that pushes predicates in a Join into the inputs to the join.

L

lookupHints(SqlNode, SqlParserPos) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

lookupNameCompletionHints(SqlValidatorScope, List<String>, SqlParserPos, Collection<SqlMoniker>) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Populates a list of all the valid alternatives for an identifier.

lookupOperatorOverloads(SqlIdentifier, SqlFunctionCategory, SqlSyntax, List<SqlOperator>, SqlNameMatcher) - Method in class org.apache.flink.table.catalog.FunctionCatalogOperatorTable

lookupQualifiedName(SqlNode, SqlParserPos) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

M

makeNullaryCall(SqlIdentifier) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

matches(RelOptRuleCall) - Method in class org.apache.flink.table.plan.rules.logical.ExtendedAggregateExtractProjectRule

N

namespaces - Variable in class org.apache.calcite.sql.validate.SqlValidatorImpl

Maps a node to the namespace which describes what columns they contain.

newValidationError(SqlNode, Resources.ExInst<SqlValidatorException>) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Node - Class in org.apache.flink.table.explain

Field hierarchy of an execution plan.

Node() - Constructor for class org.apache.flink.table.explain.Node

O

onMatch(RelOptRuleCall) - Method in class org.apache.flink.table.plan.rules.logical.ExtendedAggregateExtractProjectRule

onMatch(RelOptRuleCall) - Method in class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule.FlinkFilterIntoJoinRule

onMatch(RelOptRuleCall) - Method in class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule.FlinkJoinConditionPushRule

optionalContext() - Method in class org.apache.flink.table.executor.StreamExecutorFactory

optionalContext() - Method in class org.apache.flink.table.planner.StreamPlannerFactory

org.apache.calcite.jdbc - package org.apache.calcite.jdbc

org.apache.calcite.plan - package org.apache.calcite.plan

org.apache.calcite.sql - package org.apache.calcite.sql

org.apache.calcite.sql.validate - package org.apache.calcite.sql.validate

org.apache.calcite.sql2rel - package org.apache.calcite.sql2rel

org.apache.flink.table.api.java - package org.apache.flink.table.api.java

Table API (Java)
A BatchTableEnvironment can be used to create a Table from a DataSet.

org.apache.flink.table.calcite - package org.apache.flink.table.calcite

org.apache.flink.table.catalog - package org.apache.flink.table.catalog

org.apache.flink.table.executor - package org.apache.flink.table.executor

org.apache.flink.table.explain - package org.apache.flink.table.explain

org.apache.flink.table.expressions - package org.apache.flink.table.expressions

org.apache.flink.table.operations - package org.apache.flink.table.operations

org.apache.flink.table.plan - package org.apache.flink.table.plan

org.apache.flink.table.plan.rules.logical - package org.apache.flink.table.plan.rules.logical

org.apache.flink.table.planner - package org.apache.flink.table.planner

org.apache.flink.table.runtime.types - package org.apache.flink.table.runtime.types

org.apache.flink.table.sqlexec - package org.apache.flink.table.sqlexec

P

ParameterScope - Class in org.apache.calcite.sql.validate

A scope which contains nothing besides a few parameters.

ParameterScope(SqlValidatorImpl, Map<String, RelDataType>) - Constructor for class org.apache.calcite.sql.validate.ParameterScope

parse(String) - Method in class org.apache.flink.table.calcite.CalciteParser

Parses a SQL statement into a SqlNode.

parse(String) - Method in class org.apache.flink.table.planner.ParserImpl

parseIdentifier(String) - Method in class org.apache.flink.table.calcite.CalciteParser

Parses a SQL string as an identifier into a SqlIdentifier.

parseIdentifier(String) - Method in class org.apache.flink.table.planner.ParserImpl

ParserImpl - Class in org.apache.flink.table.planner

Implementation of Parser that uses Calcite.

ParserImpl(CatalogManager, Supplier<FlinkPlannerImpl>, Supplier<CalciteParser>) - Constructor for class org.apache.flink.table.planner.ParserImpl

perform(RelOptRuleCall, Filter, Join) - Method in class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule

performUnconditionalRewrites(SqlNode, boolean) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Performs expression rewrites which are always used unconditionally.

PlanJsonParser - Class in org.apache.flink.table.explain

Utility for converting an execution plan from JSON to a human-readable string.

PlanJsonParser() - Constructor for class org.apache.flink.table.explain.PlanJsonParser

PlannerQueryOperation - Class in org.apache.flink.table.operations

Wrapper for valid logical plans generated by Planner.

PlannerQueryOperation(RelNode) - Constructor for class org.apache.flink.table.operations.PlannerQueryOperation

PlannerTypeInferenceUtilImpl - Class in org.apache.flink.table.expressions

Implementation of PlannerTypeInferenceUtil.

PlannerTypeInferenceUtilImpl() - Constructor for class org.apache.flink.table.expressions.PlannerTypeInferenceUtilImpl

PlanningConfigurationBuilder - Class in org.apache.flink.table.planner

Utility class to create RelBuilder or FrameworkConfig used to create a corresponding Planner.

PlanningConfigurationBuilder(TableConfig, FunctionCatalog, CalciteSchema, ExpressionBridge<PlannerExpression>) - Constructor for class org.apache.flink.table.planner.PlanningConfigurationBuilder

popFunctionCall() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

pushFunctionCall() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Q

QueryOperationCatalogViewTable - Class in org.apache.flink.table.catalog

A bridge between a Flink's specific QueryOperationCatalogView and a Calcite's Table.

QueryOperationConverter - Class in org.apache.flink.table.plan

Converter from Flink's specific relational representation: QueryOperation to Calcite's specific relational representation: RelNode.

QueryOperationConverter(FlinkRelBuilder, ExpressionBridge<PlannerExpression>) - Constructor for class org.apache.flink.table.plan.QueryOperationConverter

R

registerNamespace(SqlValidatorScope, String, SqlValidatorNamespace, boolean) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Registers a new namespace, and adds it as a child of its parent scope.

RelOptCluster - Class in org.apache.calcite.plan

An environment for related relational expressions during the optimization of a query.

RelOptCluster(RelOptPlanner, RelDataTypeFactory, RexBuilder, AtomicInteger, Map<String, RelNode>) - Constructor for class org.apache.calcite.plan.RelOptCluster

Creates a cluster.

removeValidatedNodeType(SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

requiredContext() - Method in class org.apache.flink.table.executor.StreamExecutorFactory

requiredContext() - Method in class org.apache.flink.table.planner.StreamPlannerFactory

resolveColumn(String, SqlNode) - Method in class org.apache.calcite.sql.validate.ParameterScope

resolveWindow(SqlNode, SqlValidatorScope, boolean) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

runTypeInference(UnresolvedCallExpression, List<ResolvedExpression>) - Method in class org.apache.flink.table.expressions.PlannerTypeInferenceUtilImpl

S

scope - Variable in class org.apache.calcite.sql.validate.SqlValidatorImpl.IdInfo

scopes - Variable in class org.apache.calcite.sql.validate.SqlValidatorImpl

Maps query node objects to the SqlValidatorScope scope created from them.

setCallRewrite(boolean) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

setColumnReferenceExpansion(boolean) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

setDefaultNullCollation(NullCollation) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

setEnableTypeCoercion(boolean) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

setIdentifierExpansion(boolean) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

setMetadataProvider(RelMetadataProvider) - Method in class org.apache.calcite.plan.RelOptCluster

Overrides the default metadata provider for this cluster.

setOriginal(SqlNode, SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

setOriginalExpression(RexNode) - Method in class org.apache.calcite.plan.RelOptCluster

Deprecated.

setTypeCoercion(TypeCoercion) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

setValidatedNodeType(SqlNode, RelDataType) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Saves the type of a SqlNode, now that it has been validated.

shouldAllowIntermediateOrderBy() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

shouldAllowOverRelation() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

shouldExpandIdentifiers() - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

snapshot(SchemaVersion) - Method in class org.apache.flink.table.catalog.CatalogCalciteSchema

snapshot(SchemaVersion) - Method in class org.apache.flink.table.catalog.CatalogManagerCalciteSchema

SqlConversionException - Exception in org.apache.flink.table.sqlexec

Exception thrown during the execution of SQL statements.

SqlConversionException(String) - Constructor for exception org.apache.flink.table.sqlexec.SqlConversionException

SqlConversionException(String, Throwable) - Constructor for exception org.apache.flink.table.sqlexec.SqlConversionException

SqlFunction - Class in org.apache.calcite.sql

A SqlFunction is a type of operator which has conventional function-call syntax.

SqlFunction(String, SqlKind, SqlReturnTypeInference, SqlOperandTypeInference, SqlOperandTypeChecker, SqlFunctionCategory) - Constructor for class org.apache.calcite.sql.SqlFunction

Creates a new SqlFunction for a call to a builtin function.

SqlFunction(SqlIdentifier, SqlReturnTypeInference, SqlOperandTypeInference, SqlOperandTypeChecker, List<RelDataType>, SqlFunctionCategory) - Constructor for class org.apache.calcite.sql.SqlFunction

Creates a placeholder SqlFunction for an invocation of a function with a possibly qualified name.

SqlFunction(String, SqlIdentifier, SqlKind, SqlReturnTypeInference, SqlOperandTypeInference, SqlOperandTypeChecker, List<RelDataType>, SqlFunctionCategory) - Constructor for class org.apache.calcite.sql.SqlFunction

Internal constructor.

SqlToOperationConverter - Class in org.apache.flink.table.sqlexec

Mix-in tool class for SqlNode that allows DDL commands to be converted to Operation.

SqlValidatorImpl - Class in org.apache.calcite.sql.validate

Default implementation of SqlValidator.

SqlValidatorImpl(SqlOperatorTable, SqlValidatorCatalogReader, RelDataTypeFactory, SqlConformance) - Constructor for class org.apache.calcite.sql.validate.SqlValidatorImpl

Creates a validator.

SqlValidatorImpl.DmlNamespace - Class in org.apache.calcite.sql.validate

Common base class for DML statement namespaces.

SqlValidatorImpl.FunctionParamInfo - Class in org.apache.calcite.sql.validate

Utility object used to maintain information about the parameters in a function call.

SqlValidatorImpl.IdInfo - Class in org.apache.calcite.sql.validate

Information about an identifier in a particular scope.

SqlValidatorImpl.Status - Enum in org.apache.calcite.sql.validate

Validation status.

StreamExecutor - Class in org.apache.flink.table.executor

An implementation of Executor that is backed by a StreamExecutionEnvironment.

StreamExecutor(StreamExecutionEnvironment) - Constructor for class org.apache.flink.table.executor.StreamExecutor

StreamExecutorFactory - Class in org.apache.flink.table.executor

Factory to create an implementation of Executor to use in a TableEnvironment.

StreamExecutorFactory() - Constructor for class org.apache.flink.table.executor.StreamExecutorFactory

StreamPlannerFactory - Class in org.apache.flink.table.planner

Factory to construct a StreamPlanner.

StreamPlannerFactory() - Constructor for class org.apache.flink.table.planner.StreamPlannerFactory

supportedProperties() - Method in class org.apache.flink.table.executor.StreamExecutorFactory

supportedProperties() - Method in class org.apache.flink.table.planner.StreamPlannerFactory

T

toRel(RelOptTable.ToRelContext, RelOptTable) - Method in class org.apache.flink.table.catalog.QueryOperationCatalogViewTable

TRACER - Static variable in class org.apache.calcite.sql.validate.SqlValidatorImpl

traitSet() - Method in class org.apache.calcite.plan.RelOptCluster

Returns the default trait set for this cluster.

traitSetOf(RelTrait...) - Method in class org.apache.calcite.plan.RelOptCluster

Deprecated.

For traitSetOf(t1, t2), use RelOptCluster.traitSet()().replace(t1).replace(t2).

traitSetOf(RelTrait) - Method in class org.apache.calcite.plan.RelOptCluster

TRUE_PREDICATE - Static variable in class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule

Predicate that always returns true.

typeFactory - Variable in class org.apache.calcite.sql.validate.SqlValidatorImpl

U

unknownType - Variable in class org.apache.calcite.sql.validate.SqlValidatorImpl

The type of dynamic parameters until a type is imposed on them.

unparse(SqlWriter, SqlCall, int, int) - Method in class org.apache.calcite.sql.SqlFunction

UPDATE_ANON_PREFIX - Static variable in class org.apache.calcite.sql.validate.SqlValidatorImpl

Alias prefix generated for source columns when rewriting UPDATE to MERGE.

UPDATE_SRC_ALIAS - Static variable in class org.apache.calcite.sql.validate.SqlValidatorImpl

Alias generated for the source table when rewriting UPDATE to MERGE.

UPDATE_TGT_ALIAS - Static variable in class org.apache.calcite.sql.validate.SqlValidatorImpl

Alias generated for the target table when rewriting UPDATE to MERGE if no alias was specified by the user.

V

validate(SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateAggregateParams(SqlCall, SqlNode, SqlNodeList, SqlValidatorScope) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateCall(SqlCall, SqlValidator, SqlValidatorScope, SqlValidatorScope) - Method in class org.apache.calcite.sql.SqlFunction

validateCall(SqlCall, SqlValidatorScope) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateColumnListParams(SqlFunction, List<RelDataType>, List<SqlNode>) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateDataType(SqlDataTypeSpec) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateDelete(SqlDelete) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateDynamicParam(SqlDynamicParam) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateFeature(Feature, SqlParserPos) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Validates that a particular feature is enabled.

validateFrom(SqlNode, RelDataType, SqlValidatorScope) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Validates the FROM clause of a query, or (recursively) a child node of the FROM clause: AS, OVER, JOIN, VALUES, or sub-query.

validateGroupClause(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Validates the GROUP BY clause of a SELECT statement.

validateHavingClause(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateIdentifier(SqlIdentifier, SqlValidatorScope) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateInsert(SqlInsert) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateIntervalQualifier(SqlIntervalQualifier) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateJoin(SqlJoin, SqlValidatorScope) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateJoinFilters(List<RexNode>, List<RexNode>, Join, JoinRelType) - Method in class org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule

Validates that target execution framework can satisfy join filters.

validateLiteral(SqlLiteral) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateMatchRecognize(SqlCall) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateMerge(SqlMerge) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateModality(SqlSelect, SqlModality, boolean) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateNamespace(SqlValidatorNamespace, RelDataType) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Validates a namespace.

validateOrderList(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Validates the ORDER BY clause of a SELECT statement.

validateOver(SqlCall, SqlValidatorScope) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateParameterizedExpression(SqlNode, Map<String, RelDataType>) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateQuantifier(SqlValidator, SqlCall) - Method in class org.apache.calcite.sql.SqlFunction

Throws a validation error if a DISTINCT or ALL quantifier is present but not allowed.

validateQuery(SqlNode, SqlValidatorScope, RelDataType) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateSelect(SqlSelect, RelDataType) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Validates a SELECT statement.

validateSelectList(SqlNodeList, SqlSelect, RelDataType) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateSequenceValue(SqlValidatorScope, SqlIdentifier) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateUnnest(SqlCall, SqlValidatorScope, RelDataType) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateUpdate(SqlUpdate) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateValues(SqlCall, RelDataType, SqlValidatorScope) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Validates a VALUES clause.

validateWhereClause(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateWhereOrOn(SqlValidatorScope, SqlNode, String) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateWindow(SqlNode, SqlValidatorScope, SqlCall) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateWindowClause(SqlSelect) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateWith(SqlWith, SqlValidatorScope) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

validateWithItem(SqlWithItem) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

valueOf(String) - Static method in enum org.apache.calcite.sql.validate.SqlValidatorImpl.Status

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.calcite.sql.validate.SqlValidatorImpl.Status

Returns an array containing the constants of this enum type, in the order they are declared.

A C D E F G H I J L M N O P Q R S T U V