Skip to content

ExecutionStep¶

ExecutionStep<S> is an abstraction of execution steps (physical plans) to build S.

S can be one of the following:

KStreamHolder
KTableHolder
KGroupedStreamHolder
KGroupedTableHolder

Contract¶

Building S¶

S build(
  PlanBuilder planBuilder) // (1)!
S build(
  PlanBuilder planBuilder,
  PlanInfo planInfo)

Uses a PlanInfoExtractor to extract a PlanInfo

Used when:

QueryBuilder is requested for a query implementation

Extracting PlanInfo¶

PlanInfo extractPlanInfo(
  PlanInfoExtractor planInfoExtractor)

Used when:

EngineExecutor is requested to planQuery
ExecutionStep is requested to build
PlanInfoExtractor is requested to visitRepartitionStep, visitJoinStep and visitSingleSourceStep

Implementations¶