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