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

A

AbstractPythonCorrelateRuleBase - Class in org.apache.flink.table.plan.rules

The abstract physical rule base is responsible for converting FlinkLogicalCorrelate to physical Python correlate RelNode.

AbstractPythonCorrelateRuleBase(Convention, String) - Constructor for class org.apache.flink.table.plan.rules.AbstractPythonCorrelateRuleBase

AbstractPythonCorrelateRuleBase.PythonCorrelateFactoryBase - Class in org.apache.flink.table.plan.rules

The abstract factory is responsible for creating DataSetPythonCorrelate or DataStreamPythonCorrelate.

AbstractRegexParseStrategy - Class in org.apache.flink.table.parse

Strategy to parse statement to Operation by regex.

AbstractRegexParseStrategy(Pattern) - Constructor for class org.apache.flink.table.parse.AbstractRegexParseStrategy

accept(RexVisitor<R>) - Method in class org.apache.calcite.rex.RexLiteral

accept(RexBiVisitor<R, P>, P) - Method in class org.apache.calcite.rex.RexLiteral

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

addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

addDefaultKryoSerializer(Class<?>, T) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

addToSelectList(List<SqlNode>, Set<String>, List<Map.Entry<String, RelDataType>>, SqlNode, SelectScope, 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.

AdjustProjectForCountAggregateRule(RelDecorrelator.AdjustProjectForCountAggregateRule.Config) - Constructor for class org.apache.calcite.sql2rel.RelDecorrelator.AdjustProjectForCountAggregateRule

Creates an AdjustProjectForCountAggregateRule.

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

auxiliary(SqlKind) - Method in class org.apache.calcite.sql.SqlGroupedWindowFunction

Creates an auxiliary function from this grouped window function.

auxiliary(String, SqlKind) - Method in class org.apache.calcite.sql.SqlGroupedWindowFunction

Creates an auxiliary function from this grouped window function.

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.

B

BatchSelectTableSink - Class in org.apache.flink.table.sinks

A BatchTableSink for batch select job to collect the result to local.

BatchSelectTableSink(TableSchema) - Constructor for class org.apache.flink.table.sinks.BatchSelectTableSink

booleanValue(RexNode) - Static method in class org.apache.calcite.rex.RexLiteral

build(RelNode...) - Method in class org.apache.calcite.sql2rel.RelDecorrelator.CorelMapBuilder

Creates a CorelMap by iterating over a RelNode tree.

C

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

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

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

CalciteSchemaBuilder - Class in org.apache.calcite.jdbc

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

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

Rule will transpose the conditions after the Python correlate node if the join type is inner join.

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

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

CatalogCalciteSchema(boolean, String, CatalogManager, TableConfig) - 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, TableConfig, 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(SqlValidatorScope, SqlValidatorTable, RelDataType, RelDataType, SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

Checks the type assignment of an INSERT or UPDATE query.

clearJobListeners() - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

ClearOperationParseStrategy - Class in org.apache.flink.table.parse

Strategy to parse statement to ClearOperation.

cm - Variable in class org.apache.calcite.sql2rel.RelDecorrelator

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

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

computeDigest(RexDigestIncludeType) - Method in class org.apache.calcite.rex.RexLiteral

Returns a string which concisely describes the definition of this rex literal.

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

configure(String[], TypeInformation<?>[]) - Method in class org.apache.flink.table.sinks.BatchSelectTableSink

configure(String[], TypeInformation<?>[]) - Method in class org.apache.flink.table.sinks.StreamSelectTableSink

configure(ReadableConfig, ClassLoader) - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

consumeDataSet(DataSet<Row>) - Method in class org.apache.flink.table.sinks.BatchSelectTableSink

consumeDataStream(DataStream<Tuple2<Boolean, Row>>) - Method in class org.apache.flink.table.sinks.StreamSelectTableSink

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(String) - Method in class org.apache.flink.table.parse.ClearOperationParseStrategy

convert(String) - Method in interface org.apache.flink.table.parse.ExtendedParseStrategy

Convert the input statement to the Operation.

convert(String) - Method in class org.apache.flink.table.parse.HelpOperationParseStrategy

convert(String) - Method in class org.apache.flink.table.parse.QuitOperationParseStrategy

convert(String) - Method in class org.apache.flink.table.parse.ResetOperationParseStrategy

convert(String) - Method in class org.apache.flink.table.parse.SetOperationParseStrategy

convert(RelNode) - Method in class org.apache.flink.table.plan.rules.batch.DataSetPythonCorrelateRule

convert(RelNode) - Method in class org.apache.flink.table.plan.rules.stream.DataStreamPythonCorrelateRule

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.

convertToCorrelate() - Method in class org.apache.flink.table.plan.rules.AbstractPythonCorrelateRuleBase.PythonCorrelateFactoryBase

convInput - Variable in class org.apache.flink.table.plan.rules.AbstractPythonCorrelateRuleBase.PythonCorrelateFactoryBase

copy(RelTraitSet, RelNode, RexNode) - Method in class org.apache.calcite.rel.logical.LogicalSnapshot

copy(RelTraitSet, List<RelNode>) - Method in class org.apache.calcite.rel.logical.LogicalTableScan

CorelMapBuilder() - Constructor for class org.apache.calcite.sql2rel.RelDecorrelator.CorelMapBuilder

correlateRel - Variable in class org.apache.flink.table.plan.rules.AbstractPythonCorrelateRuleBase.PythonCorrelateFactoryBase

create(RelNode, RexNode) - Static method in class org.apache.calcite.rel.logical.LogicalSnapshot

Creates a LogicalSnapshot.

create(RelOptCluster, RelOptTable, List<RelHint>) - Static method in class org.apache.calcite.rel.logical.LogicalTableScan

Creates a LogicalTableScan.

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, TableSchema) - Static method in class org.apache.flink.table.catalog.QueryOperationCatalogViewTable

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

createPipeline(List<Transformation<?>>, TableConfig, String) - Method in class org.apache.flink.table.executor.StreamExecutor

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

createPythonCorrelateNode(RelNode, Option<RexNode>) - Method in class org.apache.flink.table.plan.rules.AbstractPythonCorrelateRuleBase.PythonCorrelateFactoryBase

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

DataSetPythonCorrelateRule - Class in org.apache.flink.table.plan.rules.batch

The physical rule is responsible for converting FlinkLogicalCorrelate to DataSetPythonCorrelate.

DataStreamPythonCorrelateRule - Class in org.apache.flink.table.plan.rules.stream

The physical rule is responsible for converting FlinkLogicalCorrelate to DataStreamPythonCorrelate.

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

decorrelate(RelNode) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateExpr(RelNode, Map<RelNode, RelDecorrelator.Frame>, RelDecorrelator.CorelMap, RexNode) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateQuery(RelNode) - Static method in class org.apache.calcite.sql2rel.RelDecorrelator

Deprecated.

decorrelateQuery(RelNode, RelBuilder) - Static method in class org.apache.calcite.sql2rel.RelDecorrelator

Decorrelates a query.

decorrelateRel(RelNode) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

Fallback if none of the other decorrelateRel methods match.

decorrelateRel(Sort) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateRel(Values) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateRel(LogicalAggregate) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateRel(Aggregate) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateRel(LogicalProject) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateRel(Project) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateRel(LogicalSnapshot) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateRel(LogicalTableFunctionScan) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateRel(LogicalFilter) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateRel(Filter) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateRel(LogicalCorrelate) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateRel(Correlate) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateRel(LogicalJoin) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelateRel(Join) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

decorrelator() - Method in interface org.apache.calcite.sql2rel.RelDecorrelator.Config

Returns the RelDecorrelator that will be context for the created rule instance.

DEFAULT_PATTERN_FLAGS - Static variable in class org.apache.flink.table.parse.AbstractRegexParseStrategy

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(SqlValidatorScope, SqlNode) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

disableOperatorChaining() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

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.

DummyExecutionEnvironment - Class in org.apache.flink.table.util

This is dummy ExecutionEnvironment, which holds a real ExecutionEnvironment, shares all configurations of the real environment, and disables all configuration setting methods.

DummyExecutionEnvironment(ExecutionEnvironment) - Constructor for class org.apache.flink.table.util.DummyExecutionEnvironment

DummyInputFormat() - Constructor for class org.apache.flink.table.util.DummyNoOpOperator.DummyInputFormat

DummyNoOpOperator<IN> - Class in org.apache.flink.table.util

This is dummy NoOpOperator, which context is DummyExecutionEnvironment.

DummyNoOpOperator(ExecutionEnvironment, DataSet<IN>, TypeInformation<IN>) - Constructor for class org.apache.flink.table.util.DummyNoOpOperator

DummyNoOpOperator.DummyInputFormat<IN> - Class in org.apache.flink.table.util

Provides a FileInputFormat for DummyNoOpOperator.

DummyStreamExecutionEnvironment - Class in org.apache.flink.table.util

This is dummy StreamExecutionEnvironment, which holds a real StreamExecutionEnvironment, shares all configurations of the real environment, and disables all configuration setting methods.

DummyStreamExecutionEnvironment(StreamExecutionEnvironment) - Constructor for class org.apache.flink.table.util.DummyStreamExecutionEnvironment

E

enableCheckpointing(long) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

enableCheckpointing(long, CheckpointingMode) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

enableCheckpointing(long, CheckpointingMode, boolean) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

enableCheckpointing() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

equals(Object) - Method in class org.apache.calcite.rex.RexLiteral

equals(Object) - Method in class org.apache.calcite.sql2rel.RelDecorrelator.CorelMap

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

execute() - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

execute(String) - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

execute() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

execute(String) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

execute(StreamGraph) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

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

executeAsync(String) - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

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

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

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

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

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

explainTerms(RelWriter) - Method in class org.apache.calcite.rel.logical.LogicalTableScan

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

ExtendedParser - Class in org.apache.flink.table.parse

ExtendedParser is used for parsing some special command which can't supported by CalciteParser, e.g.

ExtendedParser() - Constructor for class org.apache.flink.table.parse.ExtendedParser

ExtendedParseStrategy - Interface in org.apache.flink.table.parse

Strategy to parse statement to Operation.

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.

flavor() - Method in interface org.apache.calcite.sql2rel.RelDecorrelator.AdjustProjectForCountAggregateRule.Config

Returns the flavor of the rule (true for 4 operands, false for 3 operands).

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

Extends Calcite's SqlValidator by Flink-specific behavior.

FlinkCalciteSqlValidator(SqlOperatorTable, SqlValidatorCatalogReader, RelDataTypeFactory, SqlValidator.Config) - Constructor for class org.apache.flink.table.calcite.FlinkCalciteSqlValidator

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.

fromJdbcString(RelDataType, SqlTypeName, String) - Static method in class org.apache.calcite.rex.RexLiteral

Converts a Jdbc string into a RexLiteral.

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.

getAuxiliaryFunctions() - Method in class org.apache.calcite.sql.SqlGroupedWindowFunction

Returns a list of this grouped window function's auxiliary functions.

getBufferTimeout() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

getCachedFiles() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

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

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

getCheckpointConfig() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

getCheckpointingMode() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

getCheckpointInterval() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

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

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

getCompletionHints(String, int) - Method in class org.apache.flink.table.parse.ExtendedParser

Returns completion hints for the given statement at the given cursor position.

getCompletionHints(String, int) - Method in class org.apache.flink.table.planner.ParserImpl

getConfig() - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

getConfig() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

getConfiguration() - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

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

getConsumedDataType() - Method in class org.apache.flink.table.sinks.BatchSelectTableSink

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

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

getExecutorServiceLoader() - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

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

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

getHints() - Method in class org.apache.flink.table.parse.ClearOperationParseStrategy

getHints() - Method in interface org.apache.flink.table.parse.ExtendedParseStrategy

Return hints for the given statement.

getHints() - Method in class org.apache.flink.table.parse.HelpOperationParseStrategy

getHints() - Method in class org.apache.flink.table.parse.QuitOperationParseStrategy

getHints() - Method in class org.apache.flink.table.parse.ResetOperationParseStrategy

getHints() - Method in class org.apache.flink.table.parse.SetOperationParseStrategy

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

getInvoke(RelNode, RelNode) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

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

getKind() - Method in class org.apache.calcite.rex.RexLiteral

getLastJobExecutionResult() - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

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

getMapCorToCorRel() - Method in class org.apache.calcite.sql2rel.RelDecorrelator.CorelMap

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

getMaxParallelism() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

getMonotonicity(SqlOperatorBinding) - Method in class org.apache.calcite.sql.SqlGroupedWindowFunction

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

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

getNode() - Method in class org.apache.calcite.sql.validate.ProcedureNamespace

getNumberOfExecutionRetries() - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

getNumberOfExecutionRetries() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

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

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

getParallelism() - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

getParallelism() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

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

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

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

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

getRecordType() - Method in class org.apache.flink.table.sinks.StreamSelectTableSink

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

getRestartStrategy() - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

getRestartStrategy() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

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

getSelectResultProvider() - Method in class org.apache.flink.table.sinks.BatchSelectTableSink

getSelectResultProvider() - Method in class org.apache.flink.table.sinks.StreamSelectTableSink

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

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

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

getStateBackend() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

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

getStreamGraph() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

getStreamGraph(String) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

getStreamTimeCharacteristic() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

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

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.sinks.BatchSelectTableSink

getTableSchema() - Method in class org.apache.flink.table.sinks.StreamSelectTableSink

getType() - Method in class org.apache.calcite.rex.RexLiteral

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.sql.validate.SqlValidatorImpl

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

Returns the FlinkTypeFactory that will be used.

getTypeName() - Method in class org.apache.calcite.rex.RexLiteral

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

getUserCodeClassLoader() - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

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

getValue() - Method in class org.apache.calcite.rex.RexLiteral

Returns the value of this literal.

getValue2() - Method in class org.apache.calcite.rex.RexLiteral

Returns the value of this literal, in the form that the calculator program builder wants it.

getValue3() - Method in class org.apache.calcite.rex.RexLiteral

Returns the value of this literal, in the form that the rex-to-lix translator wants it.

getValue4() - Method in class org.apache.calcite.rex.RexLiteral

Returns the value of this literal, in the form that RexInterpreter wants it.

getValueAs(Class<T>) - Method in class org.apache.calcite.rex.RexLiteral

Returns the value of this literal as an instance of the specified class.

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

groupFunction - Variable in class org.apache.calcite.sql.SqlGroupedWindowFunction

The grouped function, if this an auxiliary function; null otherwise.

H

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

hasCorrelation() - Method in class org.apache.calcite.sql2rel.RelDecorrelator.CorelMap

Returns whether there are any correlating variables in this statement.

hashCode() - Method in class org.apache.calcite.rex.RexLiteral

hashCode() - Method in class org.apache.calcite.sql2rel.RelDecorrelator.CorelMap

HelpOperationParseStrategy - Class in org.apache.flink.table.parse

Strategy to parse statement to HelpOperation.

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 SqlParserPos 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.parse.ExtendedParser

INSTANCE - Static variable in class org.apache.flink.table.plan.rules.batch.DataSetPythonCorrelateRule

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

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

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

INSTANCE - Static variable in class org.apache.flink.table.plan.rules.stream.DataStreamPythonCorrelateRule

intValue(RexNode) - Static method in class org.apache.calcite.rex.RexLiteral

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

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

Deprecated.

isAlwaysFalse() - Method in class org.apache.calcite.rex.RexLiteral

isAlwaysTrue() - Method in class org.apache.calcite.rex.RexLiteral

isChainingEnabled() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

isForceCheckpointing() - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

isGroup() - Method in class org.apache.calcite.sql.SqlGroupedWindowFunction

isGroupAuxiliary() - Method in class org.apache.calcite.sql.SqlGroupedWindowFunction

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

isNull() - Method in class org.apache.calcite.rex.RexLiteral

Returns whether this literal's value is null.

isNullLiteral(RexNode) - Static method in class org.apache.calcite.rex.RexLiteral

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

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

isValid(Litmus, RelNode.Context) - Method in class org.apache.calcite.rel.logical.LogicalSnapshot

J

join - Variable in class org.apache.flink.table.plan.rules.AbstractPythonCorrelateRuleBase.PythonCorrelateFactoryBase

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

LogicalSnapshot - Class in org.apache.calcite.rel.logical

Sub-class of Snapshot not targeted at any particular engine or calling convention.

LogicalSnapshot(RelOptCluster, RelTraitSet, RelNode, RexNode) - Constructor for class org.apache.calcite.rel.logical.LogicalSnapshot

Creates a LogicalSnapshot.

LogicalTableScan - Class in org.apache.calcite.rel.logical

A LogicalTableScan reads all the rows from a RelOptTable.

LogicalTableScan(RelOptCluster, RelTraitSet, List<RelHint>, RelOptTable) - Constructor for class org.apache.calcite.rel.logical.LogicalTableScan

Creates a LogicalTableScan.

LogicalTableScan(RelOptCluster, RelTraitSet, RelOptTable) - Constructor for class org.apache.calcite.rel.logical.LogicalTableScan

Deprecated.

LogicalTableScan(RelOptCluster, RelOptTable) - Constructor for class org.apache.calcite.rel.logical.LogicalTableScan

Deprecated.

LogicalTableScan(RelInput) - Constructor for class org.apache.calcite.rel.logical.LogicalTableScan

Creates a LogicalTableScan by parsing serialized output.

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

match(String) - Method in class org.apache.flink.table.parse.AbstractRegexParseStrategy

match(String) - Method in interface org.apache.flink.table.parse.ExtendedParseStrategy

Determine whether the input statement is satisfied the strategy.

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

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

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

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

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

nextRecord(IN) - Method in class org.apache.flink.table.util.DummyNoOpOperator.DummyInputFormat

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

of(SortedSetMultimap<RelNode, RelDecorrelator.CorRef>, SortedMap<CorrelationId, RelNode>, Map<RexFieldAccess, RelDecorrelator.CorRef>) - Static method in class org.apache.calcite.sql2rel.RelDecorrelator.CorelMap

Creates a CorelMap with given contents.

onMatch(RelOptRuleCall) - Method in class org.apache.calcite.sql2rel.RelDecorrelator.AdjustProjectForCountAggregateRule

onMatch(RelOptRuleCall) - Method in class org.apache.calcite.sql2rel.RelDecorrelator.RemoveCorrelationForScalarAggregateRule

onMatch(RelOptRuleCall) - Method in class org.apache.calcite.sql2rel.RelDecorrelator.RemoveCorrelationForScalarProjectRule

onMatch(RelOptRuleCall) - Method in class org.apache.calcite.sql2rel.RelDecorrelator.RemoveSingleAggregateRule

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

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

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

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.rel.logical - package org.apache.calcite.rel.logical

org.apache.calcite.rex - package org.apache.calcite.rex

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.bridge.java - package org.apache.flink.table.api.bridge.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.parse - package org.apache.flink.table.parse

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

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

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

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

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

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.sinks - package org.apache.flink.table.sinks

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

org.apache.flink.table.util - package org.apache.flink.table.util

P

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

Parses a SQL statement into a SqlNode.

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

Parse the input statement to the Operation.

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

When parsing statement, it first uses ExtendedParser to parse statements.

parseIdentifier(String) - Method in class org.apache.flink.table.parse.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

parseSqlExpression(String, TableSchema) - Method in class org.apache.flink.table.planner.ParserImpl

pattern - Variable in class org.apache.flink.table.parse.AbstractRegexParseStrategy

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

printAsJava(PrintWriter) - Method in class org.apache.calcite.rex.RexLiteral

Prints the value this literal as a Java string constant.

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

Namespace whose contents are defined by the result of a call to a user-defined procedure.

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

PythonCorrelateFactoryBase(RelNode, Convention) - Constructor for class org.apache.flink.table.plan.rules.AbstractPythonCorrelateRuleBase.PythonCorrelateFactoryBase

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

Rule will split the Python FlinkLogicalTableFunctionScan with Java calls or the Java FlinkLogicalTableFunctionScan with Python calls into a FlinkLogicalCalc which will be the left input of the new FlinkLogicalCorrelate and a new FlinkLogicalTableFunctionScan.

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

QuitOperationParseStrategy - Class in org.apache.flink.table.parse

Strategy to parse statement to QuitOperation.

R

reachedEnd() - Method in class org.apache.flink.table.util.DummyNoOpOperator.DummyInputFormat

registerCachedFile(String, String) - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

registerCachedFile(String, String, boolean) - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

registerCachedFile(String, String) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

registerCachedFile(String, String, boolean) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

registerJobListener(JobListener) - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

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.

registerType(Class<?>) - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

registerType(Class<?>) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

registerTypeWithKryoSerializer(Class<?>, T) - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

registerTypeWithKryoSerializer(Class<?>, Class<? extends Serializer<?>>) - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

registerTypeWithKryoSerializer(Class<?>, T) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

registerTypeWithKryoSerializer(Class<?>, Class<? extends Serializer>) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

relBuilderFactory() - Method in class org.apache.calcite.sql2rel.RelDecorrelator

RelDecorrelator - Class in org.apache.calcite.sql2rel

Copied to fix CALCITE-4333, should be removed for the next Calcite upgrade.

RelDecorrelator(RelDecorrelator.CorelMap, Context, RelBuilder) - Constructor for class org.apache.calcite.sql2rel.RelDecorrelator

RelDecorrelator.AdjustProjectForCountAggregateRule - Class in org.apache.calcite.sql2rel

Planner rule that adjusts projects when counts are added.

RelDecorrelator.AdjustProjectForCountAggregateRule.Config - Interface in org.apache.calcite.sql2rel

Rule configuration.

RelDecorrelator.Config - Interface in org.apache.calcite.sql2rel

Base configuration for rules that are non-static in a RelDecorrelator.

RelDecorrelator.CorelMap - Class in org.apache.calcite.sql2rel

A map of the locations of Correlate in a tree of RelNodes.

RelDecorrelator.CorelMapBuilder - Class in org.apache.calcite.sql2rel

Builds a RelDecorrelator.CorelMap.

RelDecorrelator.RemoveCorrelationForScalarAggregateRule - Class in org.apache.calcite.sql2rel

Planner rule that removes correlations for scalar aggregates.

RelDecorrelator.RemoveCorrelationForScalarAggregateRule.Config - Interface in org.apache.calcite.sql2rel

Rule configuration.

RelDecorrelator.RemoveCorrelationForScalarProjectRule - Class in org.apache.calcite.sql2rel

Planner rule that removes correlations for scalar projects.

RelDecorrelator.RemoveCorrelationForScalarProjectRule.Config - Interface in org.apache.calcite.sql2rel

Rule configuration.

RelDecorrelator.RemoveSingleAggregateRule - Class in org.apache.calcite.sql2rel

Rule to remove single_value rel.

RelDecorrelator.RemoveSingleAggregateRule.Config - Interface in org.apache.calcite.sql2rel

Rule configuration.

removeCorrelationExpr(RexNode, boolean) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

removeCorrelationExpr(RexNode, boolean, RexInputRef) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

removeCorrelationExpr(RexNode, boolean, Set<Integer>) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

RemoveCorrelationForScalarAggregateRule(RelDecorrelator.RemoveCorrelationForScalarAggregateRule.Config) - Constructor for class org.apache.calcite.sql2rel.RelDecorrelator.RemoveCorrelationForScalarAggregateRule

Creates a RemoveCorrelationForScalarAggregateRule.

RemoveCorrelationForScalarProjectRule(RelDecorrelator.RemoveCorrelationForScalarProjectRule.Config) - Constructor for class org.apache.calcite.sql2rel.RelDecorrelator.RemoveCorrelationForScalarProjectRule

Creates a RemoveCorrelationForScalarProjectRule.

removeCorrelationViaRule(RelNode) - Method in class org.apache.calcite.sql2rel.RelDecorrelator

removeNullabilityCast(RexNode) - Method in class org.apache.calcite.rex.RexSimplify

Removes any casts that change nullability but not type.

RemoveSingleAggregateRule(RelDecorrelator.RemoveSingleAggregateRule.Config) - Constructor for class org.apache.calcite.sql2rel.RelDecorrelator.RemoveSingleAggregateRule

Creates a RemoveSingleAggregateRule.

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

ResetOperationParseStrategy - Class in org.apache.flink.table.parse

Strategy to parse statement to ResetOperation.

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

rexBuilder - Variable in class org.apache.calcite.rex.RexSimplify

RexLiteral - Class in org.apache.calcite.rex

Constant value in a row-expression.

RexSimplify - Class in org.apache.calcite.rex

Context required to simplify a row-expression.

RexSimplify(RexBuilder, RelOptPredicateList, RexExecutor) - Constructor for class org.apache.calcite.rex.RexSimplify

Creates a RexSimplify.

RexSimplify(RexBuilder, boolean, RexExecutor) - Constructor for class org.apache.calcite.rex.RexSimplify

Deprecated.

RexSimplify(RexBuilder, RelOptPredicateList, boolean, RexExecutor) - Constructor for class org.apache.calcite.rex.RexSimplify

Deprecated.

right - Variable in class org.apache.flink.table.plan.rules.AbstractPythonCorrelateRuleBase.PythonCorrelateFactoryBase

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.

setBufferTimeout(long) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

setMaxParallelism(int) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

setNumberOfExecutionRetries(int) - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

setNumberOfExecutionRetries(int) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

SetOperationParseStrategy - Class in org.apache.flink.table.parse

Strategy to parse statement to SetOperation.

SetOperationParseStrategy() - Constructor for class org.apache.flink.table.parse.SetOperationParseStrategy

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

setParallelism(int) - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

setParallelism(int) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

setRestartStrategy(RestartStrategies.RestartStrategyConfiguration) - Method in class org.apache.flink.table.util.DummyExecutionEnvironment

setRestartStrategy(RestartStrategies.RestartStrategyConfiguration) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

setStateBackend(StateBackend) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

setStreamTimeCharacteristic(TimeCharacteristic) - Method in class org.apache.flink.table.util.DummyStreamExecutionEnvironment

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

simplify(RexNode) - Method in class org.apache.calcite.rex.RexSimplify

Simplifies a boolean expression.

simplifyAnd(RexCall) - Method in class org.apache.calcite.rex.RexSimplify

Deprecated.

simplifyAnds(Iterable<? extends RexNode>) - Method in class org.apache.calcite.rex.RexSimplify

Deprecated.

simplifyFilterPredicates(Iterable<? extends RexNode>) - Method in class org.apache.calcite.rex.RexSimplify

Combines predicates AND, optimizes, and returns null if the result is always false.

simplifyOr(RexCall) - Method in class org.apache.calcite.rex.RexSimplify

Deprecated.

simplifyOrs(List<RexNode>) - Method in class org.apache.calcite.rex.RexSimplify

Deprecated.

simplifyPreservingType(RexNode) - Method in class org.apache.calcite.rex.RexSimplify

Simplifies a boolean expression, always preserving its type and its nullability.

simplifyPreservingType(RexNode, RexUnknownAs, boolean) - Method in class org.apache.calcite.rex.RexSimplify

simplifyUnknownAs(RexNode, RexUnknownAs) - Method in class org.apache.calcite.rex.RexSimplify

As RexSimplify.simplify(RexNode), but specifying how UNKNOWN values are to be treated.

simplifyUnknownAsFalse(RexNode) - Method in class org.apache.calcite.rex.RexSimplify

As RexSimplify.simplify(RexNode), but for a boolean expression for which a result of UNKNOWN will be treated as FALSE.

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

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

SqlGroupedWindowFunction - Class in org.apache.calcite.sql

SQL function that computes keys by which rows can be partitioned and aggregated.

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

Creates a SqlGroupedWindowFunction.

SqlGroupedWindowFunction(String, SqlKind, SqlGroupedWindowFunction, SqlOperandTypeChecker) - Constructor for class org.apache.calcite.sql.SqlGroupedWindowFunction

Creates a SqlGroupedWindowFunction.

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, the class was copied over because of CALCITE-4554.

SqlValidatorImpl(SqlOperatorTable, SqlValidatorCatalogReader, RelDataTypeFactory, SqlValidator.Config) - 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

StreamSelectTableSink - Class in org.apache.flink.table.sinks

A RetractStreamTableSink for streaming select job to collect the result to local.

StreamSelectTableSink(TableSchema) - Constructor for class org.apache.flink.table.sinks.StreamSelectTableSink

strictTypeName(RelDataType) - Static method in class org.apache.calcite.rex.RexLiteral

Returns the strict literal type for a given type.

stringValue(RexNode) - Static method in class org.apache.calcite.rex.RexLiteral

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

toRule() - Method in interface org.apache.calcite.sql2rel.RelDecorrelator.AdjustProjectForCountAggregateRule.Config

toRule() - Method in interface org.apache.calcite.sql2rel.RelDecorrelator.RemoveCorrelationForScalarAggregateRule.Config

toRule() - Method in interface org.apache.calcite.sql2rel.RelDecorrelator.RemoveCorrelationForScalarProjectRule.Config

toRule() - Method in interface org.apache.calcite.sql2rel.RelDecorrelator.RemoveSingleAggregateRule.Config

toString() - Method in class org.apache.calcite.sql2rel.RelDecorrelator.CorelMap

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

traitSet - Variable in class org.apache.flink.table.plan.rules.AbstractPythonCorrelateRuleBase.PythonCorrelateFactoryBase

transform(UnaryOperator<SqlValidator.Config>) - Method in class org.apache.calcite.sql.validate.SqlValidatorImpl

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.

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.

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

Returns the set of field names in the join condition specified by USING or implicitly by NATURAL, de-duplicated and in order.

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, 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

validateImpl(RelDataType) - Method in class org.apache.calcite.sql.validate.ProcedureNamespace

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

validateJoin(SqlJoin, SqlValidatorScope) - Method in class org.apache.flink.table.calcite.FlinkCalciteSqlValidator

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

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

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

validConstant(Object, Litmus) - Static method in class org.apache.calcite.rex.RexLiteral

Returns whether a value is valid as a constant value, using the same criteria as RexLiteral.valueMatchesType(java.lang.Comparable, org.apache.calcite.sql.type.SqlTypeName, boolean).

value(RexNode) - Static method in class org.apache.calcite.rex.RexLiteral

valueMatchesType(Comparable, SqlTypeName, boolean) - Static method in class org.apache.calcite.rex.RexLiteral

Returns whether a value is appropriate for its type.

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.

visit(RelNode) - Method in class org.apache.calcite.sql2rel.RelDecorrelator.CorelMapBuilder

visitChild(RelNode, int, RelNode) - Method in class org.apache.calcite.sql2rel.RelDecorrelator.CorelMapBuilder

W

withDecorrelator(RelDecorrelator) - Method in interface org.apache.calcite.sql2rel.RelDecorrelator.Config

Sets RelDecorrelator.Config.decorrelator().

withFlavor(boolean) - Method in interface org.apache.calcite.sql2rel.RelDecorrelator.AdjustProjectForCountAggregateRule.Config

Sets RelDecorrelator.AdjustProjectForCountAggregateRule.Config.flavor().

withHints(List<RelHint>) - Method in class org.apache.calcite.rel.logical.LogicalTableScan

withParanoid(boolean) - Method in class org.apache.calcite.rex.RexSimplify

Returns a RexSimplify the same as this but which verifies that the expression before and after simplification are equivalent.

withPredicates(RelOptPredicateList) - Method in class org.apache.calcite.rex.RexSimplify

Returns a RexSimplify the same as this but with a specified RexSimplify.predicates value.

withUnknownAsFalse(boolean) - Method in class org.apache.calcite.rex.RexSimplify

Deprecated.

Use methods with a RexUnknownAs argument, such as RexSimplify.simplify(RexNode, RexUnknownAs).

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