from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/PythonTypeUtils.java" contains "import org.apache.flink.api.java.typeutils.runtime.RowSerializer;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamPythonReduceFunctionOperator.java" contains "import org.apache.flink.api.java.typeutils.RowTypeInfo;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamTwoInputPythonStatelessFunctionOperator.java" contains "import org.apache.flink.api.java.typeutils.RowTypeInfo;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamPythonStatelessFunctionOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/datastream/runtime/typeutils/python/PythonTypeUtils.java" contains "import org.apache.flink.api.java.typeutils.RowTypeInfo;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/datastream/runtime/functions/python/PickledKeySelector.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/datastream/runtime/runners/python/beam/BeamDataStreamPythonStatelessFunctionRunner.java" contains "import org.apache.flink.api.common.typeinfo.TypeInformation;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/datastream/typeinfo/python/PickledByteArrayTypeInfo.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/python/PythonOptions.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/python/PythonConfig.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/python/PythonFunctionRunner.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/python/util/PythonConfigUtil.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/python/util/PythonDependencyUtils.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/python/util/PythonEnvironmentManagerUtils.java" contains "import org.apache.flink.util.OperatingSystem;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/python/util/ZipUtils.java" contains "import org.apache.flink.util.IOUtils;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/python/env/beam/ProcessPythonEnvironmentManager.java" contains "import org.apache.flink.util.FileUtils;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/python/metric/FlinkMetricContainer.java" contains "import org.apache.flink.configuration.GlobalConfiguration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractTwoInputPythonFunctionOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractPythonFunctionOperatorBase.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractOneInputPythonFunctionOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonFunctionRunner.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonStatelessFunctionRunner.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/table/PythonTableFunctionOperator.java" contains "import org.apache.flink.api.java.typeutils.RowTypeInfo;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/table/AbstractPythonTableFunctionOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/table/RowDataPythonTableFunctionOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/AbstractRowPythonScalarFunctionOperator.java" contains "import org.apache.flink.api.java.typeutils.RowTypeInfo;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/RowDataPythonScalarFunctionOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/AbstractRowDataPythonScalarFunctionOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/PythonScalarFunctionOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/AbstractPythonScalarFunctionOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/arrow/RowDataArrowPythonScalarFunctionOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/arrow/ArrowPythonScalarFunctionOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/AbstractStatelessFunctionOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowTimeWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowDateWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowTimestampWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowSmallIntWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowRowWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowBigIntWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowArrayWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowTinyIntWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowDoubleWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowDecimalWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowIntWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowVarBinaryWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowBooleanWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowVarCharWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowFloatWriter.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/ArrowFieldWriter.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/TimestampWriter.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/ArrayWriter.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/TimeWriter.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowTinyIntColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowDateColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowTimeColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowTimestampColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowVarCharColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowFloatColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowDoubleColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowVarBinaryColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowArrayColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowRowColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowIntColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowDecimalColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/RowDataArrowReader.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowSmallIntColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowBigIntColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowBooleanColumnVector.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/ArrowUtils.java" contains "import org.apache.flink.api.java.typeutils.TypeExtractor;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/ArrowWriter.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/serializers/RowArrowSerializer.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/AbstractArrowSourceFunction.java" contains "import org.apache.flink.api.java.typeutils.ResultTypeQueryable;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/RowArrowTableSource.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/RowArrowSourceFunction.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/ArrowSourceFunction.java" contains "import org.apache.flink.api.common.typeinfo.TypeInformation;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/RowFieldReader.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/RowArrowReader.java" contains "import org.apache.flink.types.Row;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/ArrowFieldReader.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/ArrayFieldReader.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/TimestampFieldReader.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/TimeFieldReader.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/ArrayDataSerializer.java" contains "import org.apache.flink.api.java.typeutils.runtime.DataInputViewStream;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/RowDataSerializer.java" contains "import org.apache.flink.api.java.typeutils.runtime.DataInputViewStream;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/MapDataSerializer.java" contains "import org.apache.flink.api.java.typeutils.runtime.DataInputViewStream;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/TimeSerializer.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/StringSerializer.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/TimestampSerializer.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DateSerializer.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/BigDecSerializer.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/PythonTableFunctionFlatMap.java" contains "import org.apache.flink.api.java.typeutils.RowTypeInfo;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/AbstractPythonStatelessFunctionFlatMap.java" contains "import org.apache.flink.api.java.typeutils.ResultTypeQueryable;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/AbstractPythonScalarFunctionFlatMap.java" contains "import org.apache.flink.api.java.typeutils.RowTypeInfo;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/PythonScalarFunctionFlatMap.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/arrow/ArrowPythonScalarFunctionFlatMap.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/beam/BeamTablePythonStatelessFunctionRunner.java" contains "import org.apache.flink.util.Preconditions;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/client/python/PythonFunctionFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/client/python/PythonDriver.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.java" contains "import org.apache.flink.configuration.ConfigConstants;" from: flink-python to: flink-core evidence: - file: "flink-python/src/main/java/org/apache/flink/client/cli/PythonProgramOptions.java" contains "import org.apache.flink.configuration.Configuration;"