Package | Description |
---|---|
org.apache.flink.table.planner.plan.nodes.exec.stream | |
org.apache.flink.table.planner.plan.utils |
Modifier and Type | Class and Description |
---|---|
class |
StreamExecCalc
Stream
ExecNode for Calc. |
class |
StreamExecChangelogNormalize
Stream
ExecNode which normalizes a changelog stream which maybe an upsert stream or a
changelog stream containing duplicate events. |
class |
StreamExecCorrelate
Stream
ExecNode which matches along with join a Java/Scala user defined table function. |
class |
StreamExecDeduplicate
Stream
ExecNode which deduplicate on keys and keeps only first row or last row. |
class |
StreamExecDropUpdateBefore
Stream
ExecNode which will drop the UPDATE_BEFORE messages. |
class |
StreamExecExchange
This
ExecNode represents a change of partitioning of the input elements for stream. |
class |
StreamExecExpand
Stream
ExecNode that can expand one row to multiple rows based on given projects. |
class |
StreamExecGlobalGroupAggregate
Stream
ExecNode for unbounded global group aggregate. |
class |
StreamExecGlobalWindowAggregate
Stream
ExecNode for window table-valued based global aggregate. |
class |
StreamExecGroupAggregate
Stream
ExecNode for unbounded group aggregate. |
class |
StreamExecGroupWindowAggregate
Stream
ExecNode for either group window aggregate or group window table aggregate. |
class |
StreamExecIncrementalGroupAggregate
Stream
ExecNode for unbounded incremental group aggregate. |
class |
StreamExecIntervalJoin
StreamExecNode for a time interval stream join. |
class |
StreamExecJoin
StreamExecNode for regular Joins. |
class |
StreamExecLimit
Stream
ExecNode for Limit. |
class |
StreamExecLocalGroupAggregate
Stream
ExecNode for unbounded local group aggregate. |
class |
StreamExecLocalWindowAggregate
Stream
ExecNode for window table-valued based local aggregate. |
class |
StreamExecLookupJoin
StreamExecNode for temporal table join that implemented by lookup. |
class |
StreamExecMatch
Stream
ExecNode which matches along with MATCH_RECOGNIZE. |
class |
StreamExecMiniBatchAssigner
Stream
ExecNode which injects a mini-batch event in the streaming data. |
class |
StreamExecOverAggregate
Stream
ExecNode for time-based over operator. |
class |
StreamExecPythonCalc
Stream
ExecNode for Python ScalarFunctions. |
class |
StreamExecPythonCorrelate
Stream exec node which matches along with join a Python user defined table function.
|
class |
StreamExecPythonGroupAggregate
Stream
ExecNode for Python unbounded group aggregate. |
class |
StreamExecPythonGroupWindowAggregate
Stream
ExecNode for group widow aggregate (Python user defined aggregate function). |
class |
StreamExecPythonOverAggregate
Stream
ExecNode for python time-based over operator. |
class |
StreamExecRank
Stream
ExecNode for Rank. |
class |
StreamExecSink
Stream
ExecNode to to write data into an external sink defined by a DynamicTableSink . |
class |
StreamExecSortLimit
StreamExecNode for Sort with limit. |
class |
StreamExecTableSourceScan
Stream
ExecNode to read data from an external source defined by a ScanTableSource . |
class |
StreamExecTemporalJoin
StreamExecNode for temporal table join (FOR SYSTEM_TIME AS OF) and temporal TableFunction
join (LATERAL TemporalTableFunction(o.proctime)). |
class |
StreamExecTemporalSort
StreamExecNode for time-ascending-order Sort without `limit`. |
class |
StreamExecUnion
Stream
ExecNode that is not a physical node and just union the inputs' records into one
node. |
class |
StreamExecValues
Stream
ExecNode that read records from given values. |
class |
StreamExecWatermarkAssigner
Stream
ExecNode which generates watermark based on the input elements. |
class |
StreamExecWindowAggregate
Stream
ExecNode for window table-valued based aggregate. |
class |
StreamExecWindowDeduplicate
Stream
ExecNode for Window Deduplicate. |
class |
StreamExecWindowJoin
StreamExecNode for WindowJoin. |
class |
StreamExecWindowRank
Stream
ExecNode for WindowRank. |
class |
StreamExecWindowTableFunction
Stream
ExecNode which acts as a table-valued function to assign a window for each row of
the input relation. |
Modifier and Type | Method and Description |
---|---|
static <T extends ExecNode<?>> |
ExecNodeMetadataUtil.latestAnnotation(Class<T> execNodeClass)
Returns the
ExecNodeMetadata annotation of the class with the highest (most recent)
version() . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.