from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSink.java"
   contains "import org.apache.flink.streaming.api.functions.sink.SinkFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSink.java"
   contains "import org.apache.flink.streaming.api.functions.sink.SinkFunction;"

from: flink-connectors
to: flink-streaming-java
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.streaming.api.checkpoint.ListCheckpointed;"

from: flink-connectors
to: flink-streaming-java
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.streaming.api.checkpoint.CheckpointedFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/common/AcknowledgeOnCheckpoint.java"
   contains "import org.apache.flink.streaming.api.checkpoint.ListCheckpointed;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/GenericJdbcSinkFunction.java"
   contains "import org.apache.flink.streaming.api.checkpoint.CheckpointedFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java"
   contains "import org.apache.flink.streaming.api.functions.sink.SinkFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcTableSource.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcUpsertTableSink.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java"
   contains "import org.apache.flink.streaming.runtime.operators.CheckpointCommitter;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java"
   contains "import org.apache.flink.streaming.runtime.operators.CheckpointCommitter;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSink.java"
   contains "import org.apache.flink.streaming.runtime.operators.CheckpointCommitter;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowWriteAheadSink.java"
   contains "import org.apache.flink.streaming.runtime.operators.CheckpointCommitter;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraAppendTableSink.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java"
   contains "import org.apache.flink.streaming.api.checkpoint.CheckpointedFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveContinuousMonitoringFunction.java"
   contains "import org.apache.flink.streaming.api.checkpoint.CheckpointedFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java"
   contains "import org.apache.flink.streaming.api.functions.source.TimestampedInputSplit;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java"
   contains "import org.apache.flink.streaming.api.checkpoint.CheckpointedFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java"
   contains "import org.apache.flink.streaming.api.checkpoint.CheckpointedFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java"
   contains "import org.apache.flink.streaming.api.checkpoint.CheckpointedFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkDynamoDBStreamsConsumer.java"
   contains "import org.apache.flink.streaming.api.functions.source.SourceFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/RecordEmitter.java"
   contains "import org.apache.flink.streaming.runtime.operators.windowing.TimestampedValue;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/WatermarkTracker.java"
   contains "import org.apache.flink.streaming.api.operators.StreamingRuntimeContext;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/JobManagerWatermarkTracker.java"
   contains "import org.apache.flink.streaming.api.operators.StreamingRuntimeContext;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeCallback;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java"
   contains "import org.apache.flink.streaming.api.TimeCharacteristic;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/DynamoDBStreamsDataFetcher.java"
   contains "import org.apache.flink.streaming.api.functions.source.SourceFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java"
   contains "import org.apache.flink.streaming.runtime.operators.util.AssignerWithPeriodicWatermarksAdapter;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkBase.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceBase.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-connectors
to: flink-streaming-java
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.streaming.api.datastream.DataStream;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java"
   contains "import org.apache.flink.streaming.api.checkpoint.CheckpointedFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java"
   contains "import org.apache.flink.streaming.api.operators.StreamingRuntimeContext;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer.java"
   contains "import org.apache.flink.streaming.api.operators.StreamingRuntimeContext;"

from: flink-connectors
to: flink-streaming-java
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.streaming.api.operators.StreamingRuntimeContext;"

from: flink-connectors
to: flink-streaming-java
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.streaming.api.operators.StreamingRuntimeContext;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSink.java"
   contains "import org.apache.flink.streaming.api.functions.sink.SinkFunction;"

from: flink-connectors
to: flink-streaming-java
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.streaming.api.functions.sink.SinkFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffle.java"
   contains "import org.apache.flink.streaming.util.keys.KeySelectorUtil;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java"
   contains "import org.apache.flink.streaming.api.operators.StreamingRuntimeContext;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/StreamKafkaShuffleSink.java"
   contains "import org.apache.flink.streaming.api.operators.StreamOperator;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleProducer.java"
   contains "import org.apache.flink.streaming.api.watermark.Watermark;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaShuffleFetcher.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeService;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaFetcher.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeService;"

from: flink-connectors
to: flink-streaming-java
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.streaming.runtime.tasks.ProcessingTimeService;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java"
   contains "import org.apache.flink.streaming.api.functions.sink.SinkFunction;"

from: flink-connectors
to: flink-streaming-java
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.streaming.api.functions.sink.SinkFunction;"

from: flink-connectors
to: flink-streaming-java
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.streaming.api.functions.sink.SinkFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-twitter/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterSource.java"
   contains "import org.apache.flink.streaming.api.functions.source.RichSourceFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseTableSource.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseUpsertTableSink.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java"
   contains "import org.apache.flink.streaming.api.checkpoint.CheckpointedFunction;"

from: flink-connectors
to: flink-streaming-java
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.streaming.runtime.tasks.ProcessingTimeCallback;"

from: flink-connectors
to: flink-streaming-java
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.streaming.api.functions.source.SourceFunction.SourceContext;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeCallback;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java"
   contains "import org.apache.flink.streaming.api.operators.StreamingRuntimeContext;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java"
   contains "import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-nifi/src/main/java/org/apache/flink/streaming/connectors/nifi/NiFiSource.java"
   contains "import org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction;"

from: flink-connectors
to: flink-streaming-java
evidence:
 - file: "flink-connectors/flink-connector-nifi/src/main/java/org/apache/flink/streaming/connectors/nifi/NiFiSink.java"
   contains "import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;"