KsqlStream¶

KsqlStream is a StructuredDataSource with KSTREAM type.

Creating Instance¶

KsqlStream takes the following to be created:

• SQL expression
• Source name
• LogicalSchema
• TimestampColumn
• isKsqlSink flag
• KsqlTopic
• isSourceStream flag

KsqlStream is created when:

• DdlCommandExec.Executor is requested to execute CreateStreamCommand
• KsqlStream is requested to with

with¶

DataSource with(
  String sql,
  LogicalSchema schema)

with is part of the DataSource abstraction.

with creates a new copy of this KsqlStream with the following changes:

• SQL expression is replaced with the current SQL expression with the given sql appended
• LogicalSchema replaced with the given one