Skip to content

ExecutionStepFactory

Creating StreamSource

StreamSource streamSource(
  QueryContext.Stacker stacker,
  LogicalSchema sourceSchema,
  String topicName,
  Formats formats,
  Optional<TimestampColumn> timestampColumn,
  int pseudoColumnVersion)

streamSource creates a StreamSource (with ExecutionStepPropertiesV1).

streamSource is used when:

Creating TableSelect

<K> TableSelect<K> tableMapValues(
  QueryContext.Stacker stacker,
  ExecutionStep<KTableHolder<K>> source,
  List<ColumnName> keyColumnNames,
  List<SelectExpression> selectExpressions,
  Formats format)

tableMapValues creates a TableSelect (with a new ExecutionStepPropertiesV1).

tableMapValues is used when:

  • SchemaKTable is requested to select

Creating TableSource

TableSource tableSource(
  QueryContext.Stacker stacker,
  LogicalSchema sourceSchema,
  String topicName,
  Formats formats,
  Optional<TimestampColumn> timestampColumn,
  Formats stateStoreFormats,
  int pseudoColumnVersion)

tableSource creates a TableSource (with a new ExecutionStepPropertiesV1).

tableSource is used when: