Package | Description |
---|---|
org.apache.flink.table.plan.rules.datastream |
Class and Description |
---|
DataStreamCalcRule$ |
DataStreamCorrelateRule$ |
DataStreamGroupAggregateRule$ |
DataStreamGroupWindowAggregateRule$ |
DataStreamLogicalWindowAggregateRule |
DataStreamLogicalWindowAggregateRule$ |
DataStreamOverAggregateRule$ |
DataStreamRetractionRules.AssignDefaultRetractionRule
Rule that assigns the default retraction information to
DataStreamRel nodes. |
DataStreamRetractionRules.SetAccModeRule
Sets the
AccMode of DataStreamRel nodes. |
DataStreamRetractionRules.SetUpdatesAsRetractionRule
Rule that annotates all
DataStreamRel nodes that need to sent out update changes with
retraction messages. |
DataStreamRetractionRules$
Collection of rules to annotate
DataStreamRel nodes with retraction information. |
DataStreamScanRule$ |
DataStreamUnionRule$ |
DataStreamValuesRule$ |
StreamTableSourceScanRule$ |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.