from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/CEP.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/PatternStreamBuilder.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/PatternStream.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java"
   contains "import org.apache.flink.streaming.api.windowing.time.Time;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java"
   contains "import org.apache.flink.streaming.api.windowing.time.Time;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/functions/TimedOutPartialMatchHandler.java"
   contains "import org.apache.flink.streaming.api.windowing.time.Time;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java"
   contains "import org.apache.flink.streaming.api.windowing.time.Time;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CepOperator.java"
   contains "import org.apache.flink.streaming.runtime.tasks.StreamTask;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/StreamRecordComparator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/OneInputOperatorTransformation.java"
   contains "import org.apache.flink.streaming.util.keys.KeySelectorUtil;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/BootstrapTransformation.java"
   contains "import org.apache.flink.streaming.api.operators.StreamOperator;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/SavepointWriterOperatorFactory.java"
   contains "import org.apache.flink.streaming.api.operators.StreamOperator;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/input/OperatorStateInputFormat.java"
   contains "import org.apache.flink.streaming.api.operators.BackendRestorerProcedure;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/input/KeyedStateInputFormat.java"
   contains "import org.apache.flink.streaming.api.operators.InternalTimeServiceManager;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/input/operator/KeyedStateReaderOperator.java"
   contains "import org.apache.flink.streaming.api.operators.InternalTimerService;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/input/operator/StateReaderOperator.java"
   contains "import org.apache.flink.streaming.api.operators.InternalTimeServiceManager;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/NeverFireProcessingTimeService.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeCallback;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/VoidTriggerable.java"
   contains "import org.apache.flink.streaming.api.operators.InternalTimer;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/OperatorIDGenerator.java"
   contains "import org.apache.flink.streaming.api.graph.StreamGraph;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/BoundedStreamTask.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeService;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/SnapshotUtils.java"
   contains "import org.apache.flink.streaming.api.operators.OperatorSnapshotFinalizer;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/BoundedOneInputStreamTaskRunner.java"
   contains "import org.apache.flink.streaming.api.graph.StreamConfig;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/operators/LazyTimerService.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeService;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/operators/StateBootstrapOperator.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeService;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/operators/BroadcastStateBootstrapOperator.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeService;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/operators/KeyedStateBootstrapOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/StateBootstrapFunction.java"
   contains "import org.apache.flink.streaming.api.checkpoint.CheckpointedFunction;"

from: flink-libraries
to: flink-streaming-java
evidence:
 - file: "flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/functions/KeyedStateBootstrapFunction.java"
   contains "import org.apache.flink.streaming.api.TimerService;"