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)
  1. Uses a PlanInfoExtractor to extract a PlanInfo

Used when:

Extracting PlanInfo

PlanInfo extractPlanInfo(
  PlanInfoExtractor planInfoExtractor)

Used when:

Implementations