Package | Description |
---|---|
org.apache.flink.table.planner.plan.nodes.exec.batch |
Modifier and Type | Class and Description |
---|---|
class |
BatchExecBoundedStreamScan
Batch
ExecNode to connect a given bounded DataStream and consume data from it. |
class |
BatchExecCalc
Batch
ExecNode for Calc. |
class |
BatchExecCorrelate
Batch exec node which matches along with join a Java/Scala user defined table function.
|
class |
BatchExecExchange
This
ExecNode represents a change of partitioning of the input elements for batch. |
class |
BatchExecExpand
Batch
ExecNode that can expand one row to multiple rows based on given projects. |
class |
BatchExecHashAggregate
Batch
ExecNode for hash-based aggregate operator. |
class |
BatchExecHashJoin
BatchExecNode for Hash Join. |
class |
BatchExecHashWindowAggregate
Batch
ExecNode for hash-based window aggregate operator. |
class |
BatchExecLegacySink<T>
|
class |
BatchExecLegacyTableSourceScan
Batch
ExecNode to read data from an external source defined by a bounded StreamTableSource . |
class |
BatchExecLimit
Batch
ExecNode for Limit. |
class |
BatchExecLookupJoin
BatchExecNode for temporal table join that implemented by lookup. |
class |
BatchExecMultipleInput
|
class |
BatchExecNestedLoopJoin
BatchExecNode for Nested-loop Join. |
class |
BatchExecOverAggregate
Batch
ExecNode for sort-based over window aggregate. |
class |
BatchExecOverAggregateBase
Batch
ExecNode base class for sort-based over window aggregate. |
class |
BatchExecPythonCalc
Batch
ExecNode for Python ScalarFunctions. |
class |
BatchExecPythonCorrelate
Batch exec node which matches along with join a Python user defined table function.
|
class |
BatchExecPythonGroupAggregate
Batch
ExecNode for Python unbounded group aggregate. |
class |
BatchExecPythonGroupWindowAggregate
Batch
ExecNode for group widow aggregate (Python user defined aggregate function). |
class |
BatchExecPythonOverAggregate
Batch
ExecNode for sort-based over window aggregate (Python user defined aggregate
function). |
class |
BatchExecRank
BatchExecNode for Rank. |
class |
BatchExecSink
Batch
ExecNode to to write data into an external sink defined by a DynamicTableSink . |
class |
BatchExecSort
BatchExecNode for Sort without limit. |
class |
BatchExecSortAggregate
Batch
ExecNode for (global) sort-based aggregate operator. |
class |
BatchExecSortLimit
BatchExecNode for Sort with limit. |
class |
BatchExecSortMergeJoin
BatchExecNode for Sort Merge Join. |
class |
BatchExecSortWindowAggregate
Batch
ExecNode for sort-based window aggregate operator. |
class |
BatchExecTableSourceScan
Batch
ExecNode to read data from an external source defined by a bounded ScanTableSource . |
class |
BatchExecUnion
Batch
ExecNode that is not a physical node and just union the inputs' records into one
node. |
class |
BatchExecValues
Batch
ExecNode that read records from given values. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.