Package | Description |
---|---|
org.apache.flink.table.operations | |
org.apache.flink.table.operations.utils | |
org.apache.flink.table.plan | |
org.apache.flink.table.planner.operations |
Modifier and Type | Method and Description |
---|---|
<R> R |
TableSourceQueryOperation.accept(QueryOperationVisitor<R> visitor) |
<T> T |
ScalaDataStreamQueryOperation.accept(QueryOperationVisitor<T> visitor) |
<T> T |
JavaDataStreamQueryOperation.accept(QueryOperationVisitor<T> visitor) |
<T> T |
DataSetQueryOperation.accept(QueryOperationVisitor<T> visitor) |
<T> T |
DistinctQueryOperation.accept(QueryOperationVisitor<T> visitor) |
<T> T |
FilterQueryOperation.accept(QueryOperationVisitor<T> visitor) |
<T> T |
SortQueryOperation.accept(QueryOperationVisitor<T> visitor) |
<T> T |
JoinQueryOperation.accept(QueryOperationVisitor<T> visitor) |
<T> T |
CatalogQueryOperation.accept(QueryOperationVisitor<T> visitor) |
<T> T |
WindowAggregateQueryOperation.accept(QueryOperationVisitor<T> visitor) |
<T> T |
ProjectQueryOperation.accept(QueryOperationVisitor<T> visitor) |
<T> T |
AggregateQueryOperation.accept(QueryOperationVisitor<T> visitor) |
<T> T |
SetQueryOperation.accept(QueryOperationVisitor<T> visitor) |
default <T> T |
QueryOperation.accept(QueryOperationVisitor<T> visitor) |
<U> U |
CalculatedQueryOperation.accept(QueryOperationVisitor<U> visitor) |
Modifier and Type | Class and Description |
---|---|
class |
QueryOperationDefaultVisitor<T>
A utility
QueryOperationVisitor that calls
QueryOperationDefaultVisitor.defaultMethod(QueryOperation)
by default, unless other methods are overridden explicitly. |
Modifier and Type | Class and Description |
---|---|
class |
QueryOperationConverter
Converter from Flink's specific relational representation:
QueryOperation to Calcite's specific relational
representation: RelNode . |
Modifier and Type | Method and Description |
---|---|
<T> T |
DataStreamQueryOperation.accept(QueryOperationVisitor<T> visitor) |
<T> T |
PlannerQueryOperation.accept(QueryOperationVisitor<T> visitor) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.