from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/functions/StreamingFunctionUtils.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/keys/KeySelectorUtil.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/EvictingWindowOperator.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalSingleValueProcessWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalIterableProcessAllWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalSingleValueProcessAllWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalIterableWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalIterableProcessWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalAggregateProcessWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalIterableAllWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalSingleValueAllWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalSingleValueWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalAggregateProcessAllWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/KeyGroupStreamPartitioner.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/CustomPartitionerWrapper.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java"
   contains "import org.apache.flink.api.java.Utils;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedStreams.java"
   contains "import org.apache.flink.api.java.Utils;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AsyncDataStream.java"
   contains "import org.apache.flink.api.java.Utils;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java"
   contains "import org.apache.flink.api.java.Utils;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/BroadcastConnectedStream.java"
   contains "import org.apache.flink.api.java.Utils;"

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

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java"
   contains "import org.apache.flink.api.java.Utils;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamUtils.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/IterativeStream.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/OneInputTransformation.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/KeyedMultipleInputTransformation.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/TwoInputTransformation.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SinkTransformation.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorV2.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractInput.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

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

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java"
   contains "import org.apache.flink.api.java.RemoteEnvironmentConfigUtils;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java"
   contains "import org.apache.flink.api.java.ExecutionEnvironment;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyAllWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"

from: flink-streaming-java
to: flink-java
evidence:
 - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyAllWindowFunction.java"
   contains "import org.apache.flink.api.java.operators.translation.WrappingFunction;"