Class | Description |
---|---|
DataStreamAggregateRule | |
DataStreamAggregateRule$ | |
DataStreamCalcRule | |
DataStreamCalcRule$ | |
DataStreamCorrelateRule |
Rule to convert a LogicalCorrelate into a DataStreamCorrelate.
|
DataStreamCorrelateRule$ | |
DataStreamScanRule | |
DataStreamScanRule$ | |
DataStreamUnionRule | |
DataStreamUnionRule$ | |
DataStreamValuesRule | |
DataStreamValuesRule$ | |
PushProjectIntoStreamTableSourceScanRule |
The rule is responsible for push project into a
StreamTableSourceScan |
PushProjectIntoStreamTableSourceScanRule$ | |
StreamTableSourceScanRule |
Rule to convert a
LogicalTableScan into a StreamTableSourceScan . |
StreamTableSourceScanRule$ |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.