Skip to content


StreamSelect<K> is an ExecutionStep of KStreamHolder<K>.

Creating Instance

StreamSelect takes the following to be created:

  • ExecutionStepPropertiesV1
  • Source ExecutionStep
  • Key column names
  • Select Keys
  • Select Expressions (List<SelectExpression>)

StreamSelect is created when:

Building KStreamHolder

KStreamHolder<K> build(
  PlanBuilder builder,
  PlanInfo info)

build is part of the ExecutionStep abstraction.

build requests the given PlanBuilder to visit this StreamSelect.