程序包org.apache.flink.table.planner.plan.rules.physical.stream的分层结构

程序包分层结构:

• 所有程序包

类分层结构

• java.lang.Object
  • org.apache.calcite.plan.RelOptRule
    • org.apache.calcite.plan.RelRule<C>
      • org.apache.calcite.rel.convert.ConverterRule
        • org.apache.flink.table.planner.plan.rules.physical.stream.StreamPhysicalPythonCorrelateRule
        • org.apache.flink.table.planner.plan.rules.physical.stream.StreamPhysicalPythonGroupAggregateRule
        • org.apache.flink.table.planner.plan.rules.physical.stream.StreamPhysicalPythonGroupTableAggregateRule
        • org.apache.flink.table.planner.plan.rules.physical.stream.StreamPhysicalPythonGroupWindowAggregateRule
        • org.apache.flink.table.planner.plan.rules.physical.stream.StreamPhysicalPythonOverAggregateRule
      • org.apache.flink.table.planner.plan.rules.physical.stream.PushFilterPastChangelogNormalizeRule
      • org.apache.flink.table.planner.plan.rules.physical.stream.WatermarkAssignerChangelogNormalizeTransposeRule
    • org.apache.flink.table.planner.plan.rules.physical.stream.TwoStageOptimizedWindowAggregateRule
  • org.apache.flink.table.planner.plan.rules.physical.stream.StreamPhysicalCalcRemoveRule

接口分层结构

• org.apache.calcite.plan.RelRule.Config
  • org.apache.flink.table.planner.plan.rules.physical.stream.PushFilterPastChangelogNormalizeRule.Config
  • org.apache.flink.table.planner.plan.rules.physical.stream.WatermarkAssignerChangelogNormalizeTransposeRule.Config