public interface SimplifyWindowTableFunctionRules
StreamPhysicalWindowTableFunction
to
emit per record instead of emit after watermark passed window end if time attribute is event-time
and followed by StreamPhysicalWindowRank
or StreamPhysicalWindowJoin
.Modifier and Type | Field and Description |
---|---|
static org.apache.flink.table.planner.plan.rules.physical.stream.SimplifyWindowTableFunctionWithCalcWindowRankRule |
WITH_CALC_WINDOW_RANK |
static org.apache.flink.table.planner.plan.rules.physical.stream.SimplifyWindowTableFunctionRuleWithLeftCalcWindowJoinRule |
WITH_LEFT_CALC_WINDOW_JOIN |
static org.apache.flink.table.planner.plan.rules.physical.stream.SimplifyWindowTableFunctionRuleWithLeftRightCalcWindowJoinRule |
WITH_LEFT_RIGHT_CALC_WINDOW_JOIN |
static org.apache.flink.table.planner.plan.rules.physical.stream.SimplifyWindowTableFunctionRuleWithRightCalcWindowJoinRule |
WITH_RIGHT_CALC_WINDOW_JOIN |
static org.apache.flink.table.planner.plan.rules.physical.stream.SimplifyWindowTableFunctionRuleWithWindowJoinRule |
WITH_WINDOW_JOIN |
static org.apache.flink.table.planner.plan.rules.physical.stream.SimplifyWindowTableFunctionWithWindowRankRule |
WITH_WINDOW_RANK |
static final org.apache.flink.table.planner.plan.rules.physical.stream.SimplifyWindowTableFunctionWithWindowRankRule WITH_WINDOW_RANK
static final org.apache.flink.table.planner.plan.rules.physical.stream.SimplifyWindowTableFunctionWithCalcWindowRankRule WITH_CALC_WINDOW_RANK
static final org.apache.flink.table.planner.plan.rules.physical.stream.SimplifyWindowTableFunctionRuleWithWindowJoinRule WITH_WINDOW_JOIN
static final org.apache.flink.table.planner.plan.rules.physical.stream.SimplifyWindowTableFunctionRuleWithLeftCalcWindowJoinRule WITH_LEFT_CALC_WINDOW_JOIN
static final org.apache.flink.table.planner.plan.rules.physical.stream.SimplifyWindowTableFunctionRuleWithRightCalcWindowJoinRule WITH_RIGHT_CALC_WINDOW_JOIN
static final org.apache.flink.table.planner.plan.rules.physical.stream.SimplifyWindowTableFunctionRuleWithLeftRightCalcWindowJoinRule WITH_LEFT_RIGHT_CALC_WINDOW_JOIN
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.