from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSinkFactory.java" contains "import org.apache.flink.table.sinks.UpsertStreamTableSink;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSink.java" contains "import org.apache.flink.table.api.TableSchema;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorFactory.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/KeyExtractor.java" contains "import org.apache.flink.table.types.logical.DistinctType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchValidationUtils.java" contains "import org.apache.flink.table.types.logical.DistinctType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkFactory.java" contains "import org.apache.flink.table.utils.TableSchemaUtils;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkFactory.java" contains "import org.apache.flink.table.utils.TableSchemaUtils;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java" contains "import org.apache.flink.table.connector.ChangelogMode;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java" contains "import org.apache.flink.table.connector.ChangelogMode;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7Configuration.java" contains "import org.apache.flink.table.api.ValidationException;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6Configuration.java" contains "import org.apache.flink.table.api.ValidationException;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConfiguration.java" contains "import org.apache.flink.table.api.ValidationException;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RowElasticsearchSinkFunction.java" contains "import org.apache.flink.table.api.TableException;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGenerator.java" contains "import org.apache.flink.table.data.RowData;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/StaticIndexGenerator.java" contains "import org.apache.flink.table.data.RowData;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSinkFactory.java" contains "import org.apache.flink.table.sinks.UpsertStreamTableSink;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSink.java" contains "import org.apache.flink.table.api.TableSchema;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalog.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java" contains "import org.apache.flink.table.catalog.CatalogBaseTable;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java" contains "import org.apache.flink.table.catalog.AbstractCatalog;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/factory/JdbcCatalogFactory.java" contains "import org.apache.flink.table.catalog.Catalog;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/AbstractJdbcRowConverter.java" contains "import org.apache.flink.table.types.utils.TypeConversions;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/DerbyRowConverter.java" contains "import org.apache.flink.table.types.logical.RowType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/PostgresRowConverter.java" contains "import org.apache.flink.table.types.logical.ArrayType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/MySQLRowConverter.java" contains "import org.apache.flink.table.types.logical.RowType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/JdbcRowConverter.java" contains "import org.apache.flink.table.data.RowData;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferedStatementExecutor.java" contains "import org.apache.flink.table.data.RowData;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferReducedStatementExecutor.java" contains "import org.apache.flink.table.data.RowData;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableSimpleStatementExecutor.java" contains "import org.apache.flink.table.data.RowData;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableInsertOrUpdateStatementExecutor.java" contains "import org.apache.flink.table.data.RowData;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcTypeUtil.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcTableSource.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicOutputFormatBuilder.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java" contains "import org.apache.flink.table.types.logical.RowType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcTableSourceSinkFactory.java" contains "import org.apache.flink.table.sinks.StreamTableSink;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcUpsertTableSink.java" contains "import org.apache.flink.table.sinks.TableSink;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactory.java" contains "import org.apache.flink.table.utils.TableSchemaUtils;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSink.java" contains "import org.apache.flink.table.connector.ChangelogMode;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcLookupFunction.java" contains "import org.apache.flink.table.functions.FunctionContext;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataInputFormat.java" contains "import org.apache.flink.table.data.RowData;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/AbstractDialect.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java" contains "import org.apache.flink.table.types.logical.RowType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/PostgresDialect.java" contains "import org.apache.flink.table.types.logical.LogicalTypeRoot;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/MySQLDialect.java" contains "import org.apache.flink.table.types.logical.LogicalTypeRoot;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/DerbyDialect.java" contains "import org.apache.flink.table.types.logical.LogicalTypeRoot;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraAppendTableSink.java" contains "import org.apache.flink.table.sinks.AppendStreamTableSink;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveWriterFactory.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveBulkWriterFactory.java" contains "import org.apache.flink.table.data.RowData;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveOutputFormatFactory.java" contains "import org.apache.flink.table.filesystem.OutputFormatFactory;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveRowPartitionComputer.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveRowDataPartitionComputer.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableFactory.java" contains "import org.apache.flink.table.sinks.TableSink;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveDynamicTableFactory.java" contains "import org.apache.flink.table.catalog.CatalogTable;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableMetaStoreFactory.java" contains "import org.apache.flink.table.filesystem.TableMetaStoreFactory;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HadoopFileSystemFactory.java" contains "import org.apache.flink.table.filesystem.FileSystemFactory;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveMapredSplitReader.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveVectorizedOrcSplitReader.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputFormat.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveContinuousMonitoringFunction.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveVectorizedParquetSplitReader.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/DirectoryMonitorDiscovery.java" contains "import static org.apache.flink.table.utils.PartitionPathUtils.extractPartitionValues;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableFileInputFormat.java" contains "import org.apache.flink.table.data.RowData;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/SplitReader.java" contains "import org.apache.flink.table.data.RowData;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/module/hive/HiveModule.java" contains "import org.apache.flink.table.module.Module;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/module/hive/HiveModuleFactory.java" contains "import org.apache.flink.table.module.Module;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java" contains "import org.apache.flink.sql.parser.hive.ddl.HiveDDLUtils;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveDatabaseUtil.java" contains "import org.apache.flink.sql.parser.hive.ddl.SqlAlterHiveDatabase;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveTableUtil.java" contains "import org.apache.flink.sql.parser.hive.ddl.SqlAlterHiveTable;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveTypeUtil.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveStatsUtil.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveReflectionUtils.java" contains "import org.apache.flink.table.catalog.exceptions.CatalogException;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/factories/HiveCatalogFactory.java" contains "import org.apache.flink.table.catalog.Catalog;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/factories/HiveFunctionDefinitionFactory.java" contains "import org.apache.flink.table.catalog.CatalogFunction;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV200.java" contains "import org.apache.flink.table.types.logical.LogicalType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShim.java" contains "import org.apache.flink.table.types.logical.LogicalType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV100.java" contains "import org.apache.flink.table.types.logical.LogicalType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV210.java" contains "import org.apache.flink.table.catalog.exceptions.CatalogException;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV230.java" contains "import org.apache.flink.table.catalog.exceptions.CatalogException;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV310.java" contains "import org.apache.flink.table.catalog.exceptions.CatalogException;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV110.java" contains "import org.apache.flink.table.catalog.exceptions.CatalogException;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV120.java" contains "import org.apache.flink.table.catalog.exceptions.CatalogException;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimLoader.java" contains "import org.apache.flink.table.catalog.exceptions.CatalogException;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveMetastoreClientWrapper.java" contains "import org.apache.flink.table.api.constraints.UniqueConstraint;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveSimpleUDF.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDF.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveFunction.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveScalarFunction.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDTF.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/DeferredObjectAdapter.java" contains "import org.apache.flink.table.types.logical.LogicalType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/util/HiveFunctionUtil.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/conversion/HiveInspectors.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java" contains "import org.apache.flink.table.typeutils.TypeCheckUtils;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkFactoryBase.java" contains "import org.apache.flink.table.sinks.StreamTableSink;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/index/IndexGeneratorFactory.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceBase.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryBase.java" contains "import org.apache.flink.table.sinks.StreamTableSink;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkBase.java" contains "import org.apache.flink.table.sinks.AppendStreamTableSink;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactory.java" contains "import org.apache.flink.table.sources.RowtimeAttributeDescriptor;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java" contains "import org.apache.flink.table.sources.RowtimeAttributeDescriptor;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka011TableSourceSinkFactory.java" contains "import org.apache.flink.table.sources.RowtimeAttributeDescriptor;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka011TableSource.java" contains "import org.apache.flink.table.sources.RowtimeAttributeDescriptor;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka010TableSourceSinkFactory.java" contains "import org.apache.flink.table.sources.RowtimeAttributeDescriptor;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka010TableSource.java" contains "import org.apache.flink.table.sources.RowtimeAttributeDescriptor;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSink.java" contains "import org.apache.flink.table.api.TableSchema;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka011TableSink.java" contains "import org.apache.flink.table.api.TableSchema;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka010TableSink.java" contains "import org.apache.flink.table.api.TableSchema;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryBase.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSinkBase.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSourceBase.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicSink.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicSource.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicTableFactory.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicTableFactory.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicSink.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicSource.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptions.java" contains "import org.apache.flink.table.api.TableException;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseTableSchema.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseSerde.java" contains "import org.apache.flink.table.types.DataType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseTypeUtils.java" contains "import org.apache.flink.table.types.logical.LogicalType;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseDynamicTableSource.java" contains "import org.apache.flink.table.utils.TableSchemaUtils;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseTableSource.java" contains "import org.apache.flink.table.sources.BatchTableSource;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseLookupFunction.java" contains "import org.apache.flink.table.functions.FunctionContext;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowDataLookupFunction.java" contains "import org.apache.flink.table.functions.FunctionContext;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowDataInputFormat.java" contains "import org.apache.flink.table.data.RowData;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseUpsertTableSink.java" contains "import org.apache.flink.table.sinks.TableSink;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseDynamicTableSink.java" contains "import org.apache.flink.table.connector.ChangelogMode;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/RowDataToMutationConverter.java" contains "import org.apache.flink.table.data.RowData;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/HBaseTableFactory.java" contains "import org.apache.flink.table.sinks.StreamTableSink;" from: flink-connectors to: flink-table evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/HBaseDynamicTableFactory.java" contains "import org.apache.flink.table.factories.DynamicTableSinkFactory;"