Modifier and Type | Method and Description |
---|---|
List<Operation> |
Planner.parse(String statement)
Entry point for parsing sql queries expressed as a String.
|
Modifier and Type | Method and Description |
---|---|
String |
Planner.explain(List<Operation> operations,
boolean extended)
Returns the AST of the specified Table API and SQL queries and the execution plan
to compute the result of the given collection of
QueryOperation s. |
Modifier and Type | Interface and Description |
---|---|
interface |
ModifyOperation
A
Operation that describes the DML queries such as e.g. |
interface |
QueryOperation
Base class for representing an operation structure behind a user-facing
Table API. |
Modifier and Type | Class and Description |
---|---|
class |
AggregateQueryOperation
Relational operation that performs computations on top of subsets of input rows grouped by
key.
|
class |
CalculatedQueryOperation<T>
Describes a relational operation that was created from applying a
TableFunction . |
class |
CatalogQueryOperation
Describes a relational operation that was created from a lookup to a catalog.
|
class |
CatalogSinkModifyOperation
DML operation that tells to write to a sink.
|
class |
DataSetQueryOperation<E>
Describes a relational operation that reads from a
DataSet . |
class |
DistinctQueryOperation
Removes duplicated rows of underlying relational operation.
|
class |
FilterQueryOperation
Filters out rows of underlying relational operation that do not match given condition.
|
class |
JavaDataStreamQueryOperation<E>
Describes a relational operation that reads from a
DataStream . |
class |
JoinQueryOperation
Table operation that joins two relational operations based on given condition.
|
class |
OutputConversionModifyOperation
Special, internal kind of
ModifyOperation that allows converting a tree of
QueryOperation s to a Transformation of given type described with
TypeInformation . |
class |
ProjectQueryOperation
Table operation that computes new table using given
Expression s
from its input relational operation. |
class |
ScalaDataStreamQueryOperation<E>
Describes a relational operation that reads from a
DataStream . |
class |
SetQueryOperation
A set operation on two relations.
|
class |
SortQueryOperation
Expresses sort operation of rows of the underlying relational operation with given order.
|
class |
TableSourceQueryOperation<T>
Inline scan of a
TableSource . |
class |
UnregisteredSinkModifyOperation<T>
DML operation that tells to write to the given sink.
|
class |
WindowAggregateQueryOperation
Relational operation that performs computations on top of subsets of input rows grouped by
key and group window.
|
Modifier and Type | Method and Description |
---|---|
static <T extends Operation> |
OperationUtils.formatWithChildren(String operationName,
Map<String,Object> parameters,
List<T> children,
java.util.function.Function<T,String> childToString)
Formats a Tree of
Operation in a unified way. |
Modifier and Type | Interface and Description |
---|---|
interface |
CreateOperation
A
Operation that describes the DDL statements, e.g. |
interface |
DropOperation
A
Operation that describes the DROP DDL statements, e.g. |
Modifier and Type | Class and Description |
---|---|
class |
CreateTableOperation
Operation to describe a CREATE TABLE statement.
|
class |
DropTableOperation
Operation to describe a DROP TABLE statement.
|
Modifier and Type | Class and Description |
---|---|
class |
DataStreamQueryOperation<E>
Describes a relational operation that reads from a
DataStream . |
class |
PlannerQueryOperation
Wrapper for valid logical plans generated by Planner.
|
class |
RichTableSourceQueryOperation<T>
A
TableSourceQueryOperation with FlinkStatistic and qualifiedName. |
Modifier and Type | Method and Description |
---|---|
static Operation |
SqlToOperationConverter.convert(org.apache.flink.table.planner.calcite.FlinkPlannerImpl flinkPlanner,
org.apache.calcite.sql.SqlNode sqlNode)
This is the main entrance for executing all kinds of DDL/DML
SqlNode s, different
SqlNode will have it's implementation in the #convert(type) method whose 'type' argument
is subclass of SqlNode . |
Modifier and Type | Method and Description |
---|---|
static Operation |
SqlToOperationConverter.convert(org.apache.flink.table.calcite.FlinkPlannerImpl flinkPlanner,
org.apache.calcite.sql.SqlNode sqlNode)
This is the main entrance for executing all kinds of DDL/DML
SqlNode s, different
SqlNode will have it's implementation in the #convert(type) method whose 'type' argument
is subclass of SqlNode . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.