from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/table/descriptors/JdbcValidator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/table/descriptors/ElasticsearchValidator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/table/descriptors/Elasticsearch.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/table/descriptors/HBase.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/table/descriptors/HBaseValidator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/table/descriptors/KafkaValidator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/table/descriptors/Kafka.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/JSONKeyValueDeserializationSchema.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/TypeInformationKeyValueSerializationSchema.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/KeyedSerializationSchema.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization/KeyedDeserializationSchema.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7ApiCallBridge.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7BulkProcessorIndexer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSinkFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSink.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/RestClientFactory.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7Configuration.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSinkFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6Configuration.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RequestFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/AbstractTimeIndexGenerator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6BulkProcessorIndexer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6ApiCallBridge.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSink.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/RestClientFactory.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSinkFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcNumericBetweenParametersProvider.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcGenericParameterValuesProvider.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcParameterValuesProvider.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalog.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/connection/JdbcConnectionProvider.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcBatchingOutputFormat.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/GenericJdbcSinkFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/AbstractJdbcOutputFormat.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/InsertOrUpdateJdbcExecutor.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableInsertOrUpdateStatementExecutor.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/JdbcBatchStatementExecutor.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcTypeUtil.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcInputFormat.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcOutputFormat.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcStatementBuilder.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataInputFormat.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSink.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcLookupFunction.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/NoOpCassandraFailureHandler.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraFailureHandler.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/FlinkHiveException.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableFileInputFormat.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/PartitionDiscovery.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputFormat.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/DirectoryMonitorDiscovery.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/module/hive/HiveModule.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveTypeUtil.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveMetastoreClientWrapper.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/DeferredObjectAdapter.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveSimpleUDF.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDF.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveScalarFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveFunctionWrapper.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDTF.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/util/HiveFunctionUtil.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/conversion/HiveInspectors.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/conversion/IdentityConversion.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/conversion/HiveObjectConversion.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkFactoryBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkFunction.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BufferingNoOpRequestIndexer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/PreElasticsearch6BulkProcessorIndexer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ActionRequestFailureHandler.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/NoOpFailureHandler.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/ElasticsearchUtils.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/util/IgnoringFailureHandler.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/metrics/ShardMetricsReporter.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/metrics/KinesisConsumerMetricConstants.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/KinesisShardAssigner.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/KinesisPartitioner.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/GetShardListResult.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxyInterface.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/WatermarkTracker.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/TimeoutLatch.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/JobManagerWatermarkTracker.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/RecordEmitter.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/AWSConfigConstants.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/KinesisDeserializationSchemaWrapper.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/KinesisSerializationSchema.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/serialization/KinesisDeserializationSchema.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/SequenceNumber.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/SentinelSequenceNumber.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShardState.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/StreamShardMetadata.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/StreamShardHandle.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShard.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSink.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaErrorCode.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaException.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaSerializationSchema.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaContextAware.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaDeserializationSchema.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations 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.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafka011ErrorCode.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations 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.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations 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.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleProducer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffle.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/StreamKafkaShuffleSink.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/metrics/KafkaMetricMutableWrapper.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/metrics/KafkaMetricMutableWrapper.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Handover.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaShuffleFetcher.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGenerator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaFetcher.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaInternalProducer.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaPartitionDiscoverer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/TransactionalIdsGenerator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010PartitionDiscoverer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSource.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaSinkSemantic.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopReduceFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopMapFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/HadoopReduceCombineFunction.java" contains "import org.apache.flink.annotation.Public;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/WritableTypeInfo.java" contains "import org.apache.flink.annotation.Public;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableSerializer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/wrapper/HadoopDummyReporter.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/wrapper/HadoopDummyProgressable.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/HadoopOutputFormat.java" contains "import org.apache.flink.annotation.Public;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/HadoopInputFormatBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/HadoopOutputFormatBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/HadoopInputFormat.java" contains "import org.apache.flink.annotation.Public;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/common/HadoopOutputFormatCommonBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/common/HadoopInputFormatCommonBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapreduce/HadoopOutputFormat.java" contains "import org.apache.flink.annotation.Public;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapreduce/HadoopInputFormatBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapreduce/HadoopOutputFormatBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapreduce/HadoopInputFormat.java" contains "import org.apache.flink.annotation.Public;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseOptions.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseWriteOptions.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseTableSchema.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseReadWriteHelper.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseTypeUtils.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseConfigurationUtil.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/TableInputSplit.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseDynamicTableSource.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseLookupFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowInputFormat.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/AbstractTableInputFormat.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseInputFormat.java" contains "import org.apache.flink.annotation.Experimental;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseTableSource.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowDataLookupFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseDynamicTableSink.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseUpsertTableSink.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseMutationConverter.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/HBaseTableFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/Elasticsearch5ApiCallBridge.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSink.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/config/OffsetCommitModes.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/config/OffsetCommitMode.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/config/StartupMode.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkKafkaPartitioner.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations 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.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionLeader.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartition.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractPartitionDiscoverer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaCommitCallback.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionAssigner.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionState.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicPartitionStateSentinel.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ExceptionProxy.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations 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.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/ClosableBlockingQueue.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicsDescriptor.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaConsumerMetricConstants.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/metrics/KafkaMetricWrapper.java" contains "import org.apache.flink.annotation.Internal;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSinkPublishOptions.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-connectors to: flink-annotations evidence: - file: "flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java" contains "import org.apache.flink.annotation.PublicEvolving;"