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

  • ForeignKeyTableTableJoin
  • SourceStep
  • StreamAggregate
  • StreamFilter
  • StreamFlatMap
  • StreamGroupBy
  • StreamGroupByKey
  • StreamGroupByV1
  • StreamSelect
  • StreamSelectKey
  • StreamSelectKeyV1
  • StreamSink
  • StreamStreamJoin
  • StreamTableJoin
  • StreamWindowedAggregate
  • TableAggregate
  • TableFilter
  • TableGroupBy
  • TableGroupByV1
  • TableSelect
  • TableSelectKey
  • TableSink
  • TableSuppress
  • TableTableJoin
Back to top