from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner/src/main/java/org/apache/flink/table/util/DummyStreamExecutionEnvironment.java"
   contains "import org.apache.flink.streaming.api.CheckpointingMode;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sinks/AppendStreamTableSink.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sinks/OutputFormatTableSink.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sinks/CsvTableSink.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sinks/StreamTableSink.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sinks/StreamSelectTableSink.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/PrintTableSinkFactory.java"
   contains "import org.apache.flink.streaming.api.operators.StreamingRuntimeContext;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/DataGenTableSourceFactory.java"
   contains "import org.apache.flink.streaming.api.functions.source.StatefulSequenceSource;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/BlackHoleTableSinkFactory.java"
   contains "import org.apache.flink.streaming.api.functions.sink.DiscardingSink;"

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

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/abilities/PunctuatedWatermarkAssignerProvider.java"
   contains "import org.apache.flink.streaming.api.functions.AssignerWithPunctuatedWatermarks;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/abilities/PeriodicWatermarkAssignerProvider.java"
   contains "import org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks;"

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

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/StreamTableSource.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/InputFormatTableSource.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/PunctuatedWatermarkAssigner.java"
   contains "import org.apache.flink.streaming.api.watermark.Watermark;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/BoundedOutOfOrderTimestamps.java"
   contains "import org.apache.flink.streaming.api.watermark.Watermark;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/AscendingTimestamps.java"
   contains "import org.apache.flink.streaming.api.watermark.Watermark;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/wmstrategies/PeriodicWatermarkAssigner.java"
   contains "import org.apache.flink.streaming.api.watermark.Watermark;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ExecutionEntry.java"
   contains "import org.apache.flink.streaming.api.TimeCharacteristic;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/CollectStreamResult.java"
   contains "import org.apache.flink.streaming.experimental.SocketStreamIterator;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/CollectStreamTableSink.java"
   contains "import org.apache.flink.streaming.experimental.CollectSink;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java"
   contains "import org.apache.flink.streaming.api.TimeCharacteristic;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/context/ExecutionContextImpl.java"
   contains "import org.apache.flink.streaming.api.operators.AbstractStreamOperator;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/AbstractProcessStreamOperator.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeService;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/TableStreamOperator.java"
   contains "import org.apache.flink.streaming.api.operators.AbstractStreamOperator;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/CodeGenOperatorFactory.java"
   contains "import org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/temporal/TemporalProcessTimeJoinOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/temporal/TemporalRowTimeJoinOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/temporal/BaseTwoInputStreamOperatorWithStateRetention.java"
   contains "import org.apache.flink.streaming.api.operators.AbstractStreamOperator;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/SortMergeJoinOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/HashJoinOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/KeyedCoProcessOperatorWithWatermarkDelay.java"
   contains "import org.apache.flink.streaming.api.operators.InternalTimeServiceManager;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/interval/TimeIntervalJoin.java"
   contains "import org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/stream/StreamingSemiAntiJoinOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/stream/AbstractStreamingJoinOperator.java"
   contains "import org.apache.flink.streaming.api.operators.AbstractStreamOperator;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/lookup/LookupJoinRunner.java"
   contains "import org.apache.flink.streaming.api.functions.ProcessFunction;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/lookup/DelegatingResultFuture.java"
   contains "import org.apache.flink.streaming.api.functions.async.ResultFuture;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/lookup/AsyncLookupJoinRunner.java"
   contains "import org.apache.flink.streaming.api.functions.async.AsyncFunction;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/lookup/AsyncLookupJoinWithCalcRunner.java"
   contains "import org.apache.flink.streaming.api.functions.async.AsyncFunction;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sort/RankOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sort/SortOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sort/LimitOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sort/RowTimeSortOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sort/ProcTimeSortOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sort/StreamSortOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sort/SortLimitOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sort/BaseTemporalSortOperator.java"
   contains "import org.apache.flink.streaming.api.operators.AbstractStreamOperator;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/match/RowtimeProcessFunction.java"
   contains "import org.apache.flink.streaming.api.operators.TimestampedCollector;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/ProcTimeMiniBatchAssignerOperator.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeCallback;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/WatermarkAssignerOperator.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeCallback;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/RowTimeMiniBatchAssginerOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/WatermarkAssignerOperatorFactory.java"
   contains "import org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sink/SinkOperator.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeService;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/NonBufferOverWindowOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/BufferDataOverWindowOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/ProcTimeRangeBoundedPrecedingFunction.java"
   contains "import org.apache.flink.streaming.api.operators.TimestampedCollector;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/RowTimeRowsBoundedPrecedingFunction.java"
   contains "import org.apache.flink.streaming.api.functions.KeyedProcessFunction;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/AbstractRowTimeUnboundedPrecedingOver.java"
   contains "import org.apache.flink.streaming.api.functions.KeyedProcessFunction;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/ProcTimeUnboundedPrecedingFunction.java"
   contains "import org.apache.flink.streaming.api.functions.KeyedProcessFunction;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/ProcTimeRowsBoundedPrecedingFunction.java"
   contains "import org.apache.flink.streaming.api.functions.KeyedProcessFunction;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/RowTimeRangeBoundedPrecedingFunction.java"
   contains "import org.apache.flink.streaming.api.functions.KeyedProcessFunction;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/bundle/AbstractMapBundleOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/deduplicate/DeduplicateKeepFirstRowFunction.java"
   contains "import org.apache.flink.streaming.api.functions.KeyedProcessFunction;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/deduplicate/DeduplicateKeepLastRowFunction.java"
   contains "import org.apache.flink.streaming.api.functions.KeyedProcessFunction;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java"
   contains "import org.apache.flink.streaming.api.checkpoint.CheckpointedFunction;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/AbstractTopNFunction.java"
   contains "import org.apache.flink.streaming.api.operators.KeyContext;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/StreamRecordCollector.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/partitioner/BinaryHashPartitioner.java"
   contains "import org.apache.flink.streaming.runtime.partitioner.StreamPartitioner;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/collector/TableFunctionResultFuture.java"
   contains "import org.apache.flink.streaming.api.functions.async.ResultFuture;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/CleanupState.java"
   contains "import org.apache.flink.streaming.api.TimerService;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/KeyedProcessFunctionWithCleanupState.java"
   contains "import org.apache.flink.streaming.api.TimeDomain;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSource.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSink.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/PartitionTempFileManager.java"
   contains "import org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOutputFormat.java"
   contains "import org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/PartitionCommitTrigger.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeService;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/ProcTimeCommitTigger.java"
   contains "import org.apache.flink.streaming.runtime.tasks.ProcessingTimeService;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/StreamingFileCommitter.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/StreamingFileWriter.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/operations/JavaDataStreamQueryOperation.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-scala-bridge/src/main/java/org/apache/flink/table/operations/ScalaDataStreamQueryOperation.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/internal/StreamTableEnvironmentImpl.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/StreamTableEnvironment.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/QueryOperationConverter.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/sinks/SelectTableSinkBase.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/ExecutorUtils.java"
   contains "import org.apache.flink.streaming.api.TimeCharacteristic;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/DummyStreamExecutionEnvironment.java"
   contains "import org.apache.flink.streaming.api.CheckpointingMode;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/ShuffleModeUtils.java"
   contains "import org.apache.flink.streaming.api.graph.GlobalDataExchangeMode;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/DataStreamQueryOperation.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/delegation/StreamExecutor.java"
   contains "import org.apache.flink.streaming.api.graph.StreamGraph;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/delegation/BatchExecutor.java"
   contains "import org.apache.flink.streaming.api.graph.StreamGraph;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/delegation/ExecutorBase.java"
   contains "import org.apache.flink.streaming.api.graph.StreamGraph;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/delegation/BlinkExecutorFactory.java"
   contains "import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/QueryOperationConverter.java"
   contains "import org.apache.flink.streaming.api.datastream.DataStream;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner/src/main/java/org/apache/flink/table/executor/StreamExecutor.java"
   contains "import org.apache.flink.streaming.api.graph.StreamGraph;"

from: flink-table
to: flink-streaming-java
evidence:
 - file: "flink-table/flink-table-planner/src/main/java/org/apache/flink/table/executor/StreamExecutorFactory.java"
   contains "import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;"