from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/table/descriptors/Elasticsearch.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/table/descriptors/HBase.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/table/descriptors/JdbcValidator.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/table/descriptors/JdbcCatalogDescriptor.java" contains "import org.apache.flink.util.StringUtils;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/table/descriptors/ElasticsearchValidator.java" contains "import org.apache.flink.util.StringUtils;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/table/descriptors/Kafka.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/TypeInformationKeyValueSerializationSchema.java" contains "import org.apache.flink.core.memory.DataInputDeserializer;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java" contains "import org.apache.flink.api.common.typeinfo.TypeInformation;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hcatalog/src/main/java/org/apache/flink/hcatalog/HCatInputFormatBase.java" contains "import org.apache.flink.core.io.InputSplitAssigner;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hcatalog/src/main/java/org/apache/flink/hcatalog/java/HCatInputFormat.java" contains "import org.apache.flink.api.java.tuple.Tuple;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSink.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSinkFactory.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7ApiCallBridge.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7BulkProcessorIndexer.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7Configuration.java" contains "import org.apache.flink.configuration.ReadableConfig;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6Configuration.java" contains "import org.apache.flink.configuration.ReadableConfig;" from: flink-connectors to: flink-core 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.configuration.ReadableConfig;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchOptions.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java" contains "import org.apache.flink.types.RowKind;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java" contains "import org.apache.flink.types.RowKind;" from: flink-connectors to: flink-core 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.types.Row;" from: flink-connectors to: flink-core 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.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSink.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSinkFactory.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6BulkProcessorIndexer.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6ApiCallBridge.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/splitreader/SplitReader.java" contains "import org.apache.flink.api.connector.source.SourceSplit;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/SourceReaderBase.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/SingleThreadMultiplexSourceReaderBase.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/SourceReaderOptions.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/RecordsBySplits.java" contains "import org.apache.flink.api.connector.source.SourceSplit;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/RecordEmitter.java" contains "import org.apache.flink.api.connector.source.SourceOutput;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherManager.java" contains "import org.apache.flink.util.ThrowableCatchingRunnable;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/SingleThreadFetcherManager.java" contains "import org.apache.flink.api.connector.source.SourceSplit;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/AddSplitsTask.java" contains "import org.apache.flink.api.connector.source.SourceSplit;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/FetchTask.java" contains "import org.apache.flink.api.connector.source.SourceSplit;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcher.java" contains "import org.apache.flink.api.connector.source.SourceSplit;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/event/NoMoreSplitsEvent.java" contains "import org.apache.flink.api.connector.source.SourceEvent;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSource.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSink.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/DeserializationSchemaWrapper.java" contains "import org.apache.flink.util.Collector;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/BlockingGrpcPubSubSubscriber.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/common/PubSubDeserializationSchema.java" contains "import org.apache.flink.util.Collector;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcNumericBetweenParametersProvider.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java" contains "import org.apache.flink.util.StringUtils;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresTablePath.java" contains "import org.apache.flink.util.StringUtils;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalogUtils.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcInsertOptions.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcOptions.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/AbstractJdbcRowConverter.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/GenericJdbcSinkFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/AbstractJdbcOutputFormat.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/TableJdbcUpsertOutputFormat.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcBatchingOutputFormat.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferReducedStatementExecutor.java" contains "import org.apache.flink.types.RowKind;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/InsertOrUpdateJdbcExecutor.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableSimpleStatementExecutor.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableInsertOrUpdateStatementExecutor.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/statement/FieldNamedPreparedStatementImpl.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcUtils.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcTypeUtil.java" contains "import org.apache.flink.api.common.typeinfo.LocalTimeTypeInfo;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcInputFormat.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcOutputFormat.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcStatementBuilder.java" contains "import org.apache.flink.util.function.BiConsumerWithException;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataInputFormat.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcTableSourceSinkFactory.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcTableSource.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSink.java" contains "import org.apache.flink.types.RowKind;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcUpsertTableSink.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcLookupFunction.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicOutputFormatBuilder.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/AbstractCassandraTupleSink.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraPojoSink.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowSink.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowWriteAheadSink.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraAppendTableSink.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBaseConfig.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleSink.java" contains "import org.apache.flink.api.java.tuple.Tuple;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSink.java" contains "import org.apache.flink.api.java.tuple.Tuple;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java" contains "import org.apache.flink.api.java.ClosureCleaner;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraInputFormatBase.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormatBase.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraPojoOutputFormat.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraRowOutputFormat.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraPojoInputFormat.java" contains "import org.apache.flink.core.io.InputSplit;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraInputFormat.java" contains "import org.apache.flink.core.io.InputSplit;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormat.java" contains "import org.apache.flink.api.java.tuple.Tuple;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraTupleOutputFormat.java" contains "import org.apache.flink.api.java.tuple.Tuple;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveOutputFormatFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveWriterFactory.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveDynamicTableFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveOptions.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveRowPartitionComputer.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableMetaStoreFactory.java" contains "import org.apache.flink.core.fs.Path;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HadoopFileSystemFactory.java" contains "import org.apache.flink.core.fs.FileSystem;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableFactory.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTablePartition.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableFileInputFormat.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputFormat.java" contains "import org.apache.flink.core.io.InputSplitAssigner;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveVectorizedOrcSplitReader.java" contains "import org.apache.flink.core.fs.Path;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveVectorizedParquetSplitReader.java" contains "import org.apache.flink.core.fs.Path;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputSplit.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveContinuousMonitoringFunction.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/PartitionDiscovery.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/DirectoryMonitorDiscovery.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/module/hive/HiveModule.java" contains "import org.apache.flink.util.StringUtils;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveTypeUtil.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveTableUtil.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveStatsUtil.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/descriptors/HiveCatalogDescriptor.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/factories/HiveFunctionDefinitionFactory.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV210.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveMetastoreClientFactory.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveMetastoreClientWrapper.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV310.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV110.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV100.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV200.java" contains "import org.apache.flink.api.common.serialization.BulkWriter;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShim.java" contains "import org.apache.flink.api.common.serialization.BulkWriter;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDTF.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveSimpleUDF.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/FlinkHiveUDFException.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java" contains "import org.apache.flink.api.common.typeinfo.TypeInformation;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveScalarFunction.java" contains "import org.apache.flink.api.common.typeinfo.TypeInformation;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/conversion/HiveInspectors.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkFactoryBase.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/PreElasticsearch6BulkProcessorIndexer.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkFunction.java" contains "import org.apache.flink.api.common.functions.Function;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/RetryRejectedExecutionFailureHandler.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/index/IndexGenerator.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core 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.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/index/StaticIndexGenerator.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java" contains "import org.apache.flink.util.InstantiationUtil;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkDynamoDBStreamsConsumer.java" contains "import org.apache.flink.api.common.serialization.DeserializationSchema;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/JobManagerWatermarkTracker.java" contains "import org.apache.flink.util.InstantiationUtil;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/WatermarkTracker.java" contains "import org.apache.flink.api.common.functions.RuntimeContext;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/KinesisDeserializationSchemaWrapper.java" contains "import org.apache.flink.util.Collector;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/KinesisSerializationSchema.java" contains "import org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/KinesisDeserializationSchema.java" contains "import org.apache.flink.api.common.serialization.DeserializationSchema;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/DynamoDBStreamsSchema.java" contains "import org.apache.flink.api.common.typeinfo.TypeInformation;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java" contains "import org.apache.flink.util.InstantiationUtil;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/DynamoDBStreamsDataFetcher.java" contains "import org.apache.flink.api.common.functions.RuntimeContext;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/SequenceNumber.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShardState.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/StreamShardMetadata.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/StreamShardHandle.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShard.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactory.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSink.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryBase.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkBase.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceBase.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core 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.types.Row;" from: flink-connectors to: flink-core 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.types.Row;" from: flink-connectors to: flink-core 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.types.Row;" from: flink-connectors to: flink-core 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.types.Row;" from: flink-connectors to: flink-core 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.types.Row;" from: flink-connectors to: flink-core 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.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java" contains "import org.apache.flink.util.PropertiesUtil;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaDeserializationSchema.java" contains "import org.apache.flink.util.Collector;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafka011Exception.java" contains "import org.apache.flink.util.FlinkException;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java" contains "import org.apache.flink.util.PropertiesUtil;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java" contains "import org.apache.flink.api.common.typeutils.SimpleTypeSerializerSnapshot;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaSerializationSchema.java" contains "import org.apache.flink.api.common.serialization.SerializationSchema;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer011.java" contains "import org.apache.flink.api.common.serialization.DeserializationSchema;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java" contains "import org.apache.flink.api.common.serialization.SerializationSchema;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleProducer.java" contains "import org.apache.flink.core.memory.DataOutputSerializer;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffle.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaShuffleFetcher.java" contains "import org.apache.flink.core.memory.DataInputDeserializer;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGenerator.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaFetcher.java" contains "import org.apache.flink.util.Collector;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaInternalProducer.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaPartitionDiscoverer.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaProducer.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGenerator.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010PartitionDiscoverer.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010Fetcher.java" contains "import org.apache.flink.util.Collector;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core 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.configuration.ConfigOption;" from: flink-connectors to: flink-core 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.configuration.ConfigOption;" from: flink-connectors to: flink-core 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.configuration.ConfigOption;" from: flink-connectors to: flink-core 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.util.Preconditions;" from: flink-connectors to: flink-core 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.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java" contains "import org.apache.flink.api.common.serialization.SerializationSchema;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java" contains "import org.apache.flink.api.common.serialization.DeserializationSchema;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactory.java" contains "import org.apache.flink.api.common.serialization.DeserializationSchema;" from: flink-connectors to: flink-core 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.api.common.serialization.SerializationSchema;" from: flink-connectors to: flink-core 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.api.common.serialization.DeserializationSchema;" from: flink-connectors to: flink-core 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.api.common.serialization.DeserializationSchema;" from: flink-connectors to: flink-core 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.api.common.serialization.SerializationSchema;" from: flink-connectors to: flink-core 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.api.common.serialization.DeserializationSchema;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-twitter/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterSource.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/HadoopInputs.java" contains "import org.apache.flink.api.common.io.InputFormat;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopReduceFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopMapFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopReduceCombineFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/wrapper/HadoopTupleUnwrappingIterator.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/wrapper/HadoopOutputCollector.java" contains "import org.apache.flink.util.Collector;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/wrapper/HadoopInputSplit.java" contains "import org.apache.flink.core.io.InputSplit;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/utils/HadoopUtils.java" contains "import org.apache.flink.configuration.ConfigConstants;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/HadoopInputFormatBase.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/HadoopOutputFormatBase.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/HadoopOutputFormat.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/HadoopInputFormat.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/common/HadoopInputFormatCommonBase.java" contains "import org.apache.flink.core.io.InputSplit;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/common/HadoopOutputFormatCommonBase.java" contains "import org.apache.flink.api.common.io.RichOutputFormat;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapreduce/wrapper/HadoopInputSplit.java" contains "import org.apache.flink.core.io.InputSplit;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapreduce/utils/HadoopUtils.java" contains "import org.apache.flink.configuration.GlobalConfiguration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapreduce/HadoopInputFormatBase.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapreduce/HadoopOutputFormatBase.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapreduce/HadoopOutputFormat.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapreduce/HadoopInputFormat.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java" contains "import org.apache.flink.api.java.tuple.Tuple;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseOptions.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseReadWriteHelper.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseTableSchema.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseSerde.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseConfigurationUtil.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseTypeUtils.java" contains "import org.apache.flink.api.common.typeinfo.TypeInformation;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowInputFormat.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowDataInputFormat.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/AbstractTableInputFormat.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseInputFormat.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseLookupFunction.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseTableSource.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/TableInputSplit.java" contains "import org.apache.flink.core.io.LocatableInputSplit;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseDynamicTableSource.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowDataLookupFunction.java" contains "import org.apache.flink.util.StringUtils;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/LegacyMutationConverter.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseDynamicTableSink.java" contains "import org.apache.flink.types.RowKind;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseUpsertTableSink.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/RowDataToMutationConverter.java" contains "import org.apache.flink.types.RowKind;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/HBaseDynamicTableFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/HBaseTableFactory.java" contains "import org.apache.flink.types.Row;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/Elasticsearch5ApiCallBridge.java" contains "import org.apache.flink.util.IOUtils;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscoverer.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java" contains "import org.apache.flink.util.SerializedValue;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaDeserializationSchemaWrapper.java" contains "import org.apache.flink.util.Collector;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicsDescriptor.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaSerializationSchemaWrapper.java" contains "import org.apache.flink.api.common.serialization.SerializationSchema;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KeyedSerializationSchemaWrapper.java" contains "import org.apache.flink.api.common.serialization.SerializationSchema;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionStateWithWatermarkGenerator.java" contains "import org.apache.flink.api.common.eventtime.TimestampAssigner;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/SourceContextWatermarkOutputAdapter.java" contains "import org.apache.flink.api.common.eventtime.Watermark;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/SequenceFileWriter.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/AvroKeyValueSinkWriter.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/DateTimeBucketer.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java" contains "import org.apache.flink.util.Preconditions;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-nifi/src/main/java/org/apache/flink/streaming/connectors/nifi/NiFiSink.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-nifi/src/main/java/org/apache/flink/streaming/connectors/nifi/NiFiSource.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-connectors to: flink-core evidence: - file: "flink-connectors/flink-connector-nifi/src/main/java/org/apache/flink/streaming/connectors/nifi/NiFiDataPacketBuilder.java" contains "import org.apache.flink.api.common.functions.Function;"