StreamSelect¶

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:

• ExecutionStepFactory is requested to streamSelect

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.