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.

streamSource is used when:

Back to top