(flink) 01/02: [FLINK-37878][table] Extract PlannerBase#applyProcessors and make it public

[snuyanzin]

This is an automated email from the ASF dual-hosted git repository.

snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 6936b2ae594112622ec09cf6d7f38f544499d1b4
Author: Sergey Nuyanzin <snuyan...@gmail.com>
AuthorDate: Fri May 30 11:35:51 2025 +0200

    [FLINK-37878][table] Extract PlannerBase#applyProcessors and make it public
---
 .../scala/org/apache/flink/table/planner/delegation/PlannerBase.scala | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/PlannerBase.scala
 
b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/PlannerBase.scala
index da4f0b26cdf..ac3aa1fbf2d 100644
--- 
a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/PlannerBase.scala
+++ 
b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/PlannerBase.scala
@@ -426,6 +426,10 @@ abstract class PlannerBase(
     val execGraph =
       
generator.generate(optimizedRelNodes.map(_.asInstanceOf[FlinkPhysicalRel]), 
isCompiled)
 
+    applyProcessors(execGraph)
+  }
+
+  def applyProcessors(execGraph: ExecNodeGraph): ExecNodeGraph = {
     // process the graph
     val context = new ProcessorContext(this)
     val processors = getExecNodeGraphProcessors