Page History

abstract class PlannerBase(
    executor: Executor,
    tableConfig: TableConfig,
    val moduleManager: ModuleManager,
    val functionCatalog: FunctionCatalog,
    val catalogManager: CatalogManager,
    isStreamingMode: Boolean,
    classLoader: ClassLoader)
  extends Planner {
    @VisibleForTesting
    private[flink] def translateToExecNodeGraph(
        optimizedRelNodes: Seq[RelNode],
        isCompiled: Boolean): ExecNodeGraph = {
        ...;
        val// Get processors = getExecNodeGraphProcessors
        // Add with dynamic parameter processor
 to processors
      val  addDynamicParameterProcessor(processors)processors = getExecNodeGraphProcessors
        processors.foldLeft(execGraph)((graph, processor) => processor.process(graph, context))
    }
    
    private def addDynamicParameterProcessor(processors: Seq[ExecNodeGraphProcessor]): Unit = {
        // Create dynamic parameter process from table config and add it to processors
    }       
}