[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1064259324 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -60,318 +69,470 @@ public class

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1064235043 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -45,153 +52,177 @@ import

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1064234998 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -45,153 +52,177 @@ import

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1063265717 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -137,6 +140,20 @@ private static

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1063260676 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/program/FlinkDynamicPartitionPruningProgram.java: ## @@ -0,0 +1,151 @@

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1063258059 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/program/FlinkDynamicPartitionPruningProgram.java: ## @@ -0,0 +1,151 @@

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1061446831 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -201,33 +224,128 @@ private static

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1061096672 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -258,7 +376,14 @@ private static void

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1058791517 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/program/FlinkDynamicPartitionPruningConverterProgram.java: ## @@ -0,0

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1057207173 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -201,33 +224,128 @@ private static

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1057127105 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/program/FlinkDynamicPartitionPruningConverterProgram.java: ## @@ -0,0

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1057124031 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/program/FlinkDynamicPartitionPruningConverterProgram.java: ## @@ -0,0

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1057120484 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -275,6 +400,19 @@ &&

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1057118501 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -201,33 +224,128 @@ private static

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1057114326 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -60,138 +68,153 @@ public class

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1057113411 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -60,138 +68,153 @@ public class

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1057112096 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChainedProgram.scala: ## @@ -59,6 +59,10 @@ class

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1057111849 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkBatchProgram.scala: ## @@ -40,6 +40,7 @@ object

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1057111352 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/program/FlinkDynamicPartitionPruningConverterProgram.java: ## @@ -0,0

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1057109304 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/program/FlinkDynamicPartitionPruningConverterProgram.java: ## @@ -0,0