class StructuredDataSource implements DataSource {

  @Override
  public DataSourceType getDataSourceType() {
    return this.dataSourceType;
  }

  public  StructuredDataSource(
      String sqlExpression,
      final String datasourceName,
      final Schema schema,
      final Field keyField,
      final TimestampExtractionPolicy timestampExtractionPolicy,
      final DataSourceType dataSourceType,
      final KsqlTopic ksqlTopic
  );

}