StructuredDataSource¶
StructuredDataSource is an extension of the DataSource abstraction for data sources with a schema.
Implementations¶
- KsqlStream
KsqlTable
Creating Instance¶
StructuredDataSource takes the following to be created:
- SQL expression
- Data source name
- LogicalSchema
-
TimestampColumn - DataSourceType
-
casTargetflag -
KsqlTopic -
isSourceflag
Abstract Class
StructuredDataSource is an abstract class and cannot be created directly. It is created indirectly for the concrete StructuredDataSources.