from: flink-python
to: flink-streaming-java
evidence:
 - file: "flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamPythonReduceFunctionOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-python
to: flink-streaming-java
evidence:
 - file: "flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamTwoInputPythonStatelessFunctionOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-python
to: flink-streaming-java
evidence:
 - file: "flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamPythonStatelessFunctionOperator.java"
   contains "import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;"

from: flink-python
to: flink-streaming-java
evidence:
 - file: "flink-python/src/main/java/org/apache/flink/python/util/PythonConfigUtil.java"
   contains "import org.apache.flink.streaming.runtime.partitioner.ForwardPartitioner;"

from: flink-python
to: flink-streaming-java
evidence:
 - file: "flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractTwoInputPythonFunctionOperator.java"
   contains "import org.apache.flink.streaming.api.operators.BoundedMultiInput;"

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

from: flink-python
to: flink-streaming-java
evidence:
 - file: "flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractOneInputPythonFunctionOperator.java"
   contains "import org.apache.flink.streaming.api.operators.BoundedOneInput;"

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

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

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

from: flink-python
to: flink-streaming-java
evidence:
 - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/AbstractArrowSourceFunction.java"
   contains "import org.apache.flink.streaming.api.checkpoint.CheckpointedFunction;"

from: flink-python
to: flink-streaming-java
evidence:
 - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/RowArrowSourceFunction.java"
   contains "import org.apache.flink.streaming.api.functions.source.SourceFunction;"

from: flink-python
to: flink-streaming-java
evidence:
 - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/ArrowSourceFunction.java"
   contains "import org.apache.flink.streaming.api.functions.source.SourceFunction;"