DataSource¶

DataSource is an abstraction of data sources.

Contract (Subset)¶

getDataSourceType¶

DataSourceType getDataSourceType()

DataSourceType of this DataSource

getSchema¶

LogicalSchema getSchema()

LogicalSchema of this DataSource

See StructuredDataSource

getTimestampColumn¶

Optional<TimestampColumn> getTimestampColumn()

Used when:

• SchemaKSourceFactory is requested to buildWindowedStream, buildStream, buildWindowedTable, buildTable
• KsqlStream is requested to with
• KsqlTable is requested to with
• StructuredDataSource is requested for the PROPERTIES
• SourceDescriptionFactory is requested to create

isSource¶

boolean isSource()

Used when:

• AlterSourceFactory is requested to create
• CreateSourceFactory is requested to throwIfCreateOrReplaceOnSourceStreamOrTable
• DropSourceFactory is requested to create
• EngineExecutor is requested to execute a plan
• TopicDeleteInjector is requested to inject
• KsqlStream is requested to with
• KsqlTable is requested to with
• InsertValuesExecutor is requested to getDataSource

with¶

DataSource with(
  String sql,
  LogicalSchema schema)

Creates a copy of this DataSource with the given SQL appended and the given LogicalSchema

Used when:

• DdlCommandExec.Executor is requested to execute AlterSourceCommand

Implementations¶

• StructuredDataSource

DataSourceType¶

KSTREAM¶

KTABLE¶