Interface | Description |
---|---|
DataStreamRel | |
StreamScan |
Class | Description |
---|---|
AccMode |
The
AccMode determines how insert, update, and delete changes of tables are encoded
by the messeages that an operator emits. |
AccMode$ |
The
AccMode determines how insert, update, and delete changes of tables are encoded
by the messeages that an operator emits. |
AccModeTrait |
Tracks the AccMode of a
RelNode . |
AccModeTrait$ | |
AccModeTraitDef |
Definition of the
AccModeTrait . |
AccModeTraitDef$ | |
DataStreamCalc |
Flink RelNode which matches along with FlatMapOperator.
|
DataStreamCorrelate |
Flink RelNode which matches along with join a user defined table function.
|
DataStreamGroupAggregate |
Flink RelNode for data stream unbounded group aggregate
|
DataStreamGroupWindowAggregate | |
DataStreamGroupWindowAggregate$ | |
DataStreamOverAggregate | |
DataStreamScan |
Flink RelNode which matches along with DataStreamSource.
|
DataStreamUnion |
Flink RelNode which matches along with Union.
|
DataStreamValues |
DataStream RelNode for LogicalValues.
|
StreamTableSourceScan |
Flink RelNode to read data from an external source defined by a
StreamTableSource . |
UpdateAsRetractionTrait |
Tracks if a
RelNode needs to send update and delete changes as
retraction messages. |
UpdateAsRetractionTrait$ | |
UpdateAsRetractionTraitDef |
Definition of the
UpdateAsRetractionTrait . |
UpdateAsRetractionTraitDef$ |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.