PhysicalPlanBuilder¶
Creating Instance¶
PhysicalPlanBuilder
takes the following to be created:
-
StreamsBuilder
(Kafka Streams) - KsqlConfig
- ServiceContext
-
ProcessingLogContext
-
FunctionRegistry
PhysicalPlanBuilder
is created when:
QueryEngine
is requested to build a physical plan
Building Physical Plan¶
PhysicalPlan buildPhysicalPlan(
LogicalPlanNode logicalPlanNode,
QueryId queryId,
Optional<PlanInfo> oldPlanInfo)
buildPhysicalPlan
...FIXME
buildPhysicalPlan
is used when:
QueryEngine
is requested to build a physical plan