from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/table/descriptors/Json.java" contains "import org.apache.flink.types.Row;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-csv/src/main/java/org/apache/flink/table/descriptors/Csv.java" contains "import org.apache.flink.types.Row;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/table/descriptors/Avro.java" contains "import org.apache.flink.util.Preconditions;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/HadoopPathBasedBulkFormatBuilder.java" contains "import org.apache.flink.core.fs.Path;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/formats/hadoop/bulk/HadoopPathBasedPartFileWriter.java" contains "import org.apache.flink.core.io.SimpleVersionedSerializer;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/formats/hadoop/bulk/HadoopPathBasedBulkWriter.java" contains "import org.apache.flink.api.common.serialization.BulkWriter;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/formats/hadoop/bulk/committer/HadoopRenameFileCommitter.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcBatchReader.java" contains "import org.apache.flink.api.java.typeutils.MapTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java" contains "import org.apache.flink.api.java.typeutils.ResultTypeQueryable;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcTableSource.java" contains "import org.apache.flink.api.java.typeutils.RowTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcFileSystemFormatFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcRowSplitReader.java" contains "import org.apache.flink.types.Row;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcSplitReaderUtil.java" contains "import org.apache.flink.core.fs.Path;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcInputFormat.java" contains "import org.apache.flink.core.fs.Path;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcColumnarRowSplitReader.java" contains "import org.apache.flink.core.fs.Path;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcSplitReader.java" contains "import org.apache.flink.core.fs.Path;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc/src/main/java/org/apache/flink/orc/writer/PhysicalWriterImpl.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc/src/main/java/org/apache/flink/orc/writer/OrcBulkWriterFactory.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc/src/main/java/org/apache/flink/orc/writer/OrcBulkWriter.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc/src/main/java/org/apache/flink/orc/shim/OrcShimV200.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/Vectorizer.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java" contains "import org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonFileSystemFormatFactory.java" contains "import org.apache.flink.api.java.typeutils.GenericTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowFormatFactory.java" contains "import org.apache.flink.api.java.typeutils.RowTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java" contains "import org.apache.flink.api.java.typeutils.MapTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonFormatFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonOptions.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSchemaConverter.java" contains "import org.apache.flink.types.Row;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java" contains "import org.apache.flink.api.common.serialization.SerializationSchema;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonNodeDeserializationSchema.java" contains "import org.apache.flink.api.common.serialization.AbstractDeserializationSchema;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonFormatFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java" contains "import org.apache.flink.types.RowKind;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonFormatFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java" contains "import org.apache.flink.types.RowKind;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java" contains "import org.apache.flink.types.RowKind;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonFormatFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java" contains "import org.apache.flink.types.RowKind;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroInputFormat.java" contains "import org.apache.flink.api.java.typeutils.ResultTypeQueryable;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java" contains "import org.apache.flink.api.java.typeutils.MapTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroOutputFormat.java" contains "import org.apache.flink.configuration.ConfigConstants;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroFormatFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroFileSystemFormatFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java" contains "import org.apache.flink.types.Row;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowFormatFactory.java" contains "import org.apache.flink.types.Row;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroWriterFactory.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java" contains "import org.apache.flink.util.WrappingRuntimeException;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java" contains "import org.apache.flink.util.Preconditions;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java" contains "import org.apache.flink.util.Preconditions;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java" contains "import org.apache.flink.api.common.serialization.DeserializationSchema;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java" contains "import org.apache.flink.api.common.serialization.SerializationSchema;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroBulkWriter.java" contains "import org.apache.flink.api.common.serialization.BulkWriter;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java" contains "import org.apache.flink.api.java.typeutils.RowTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroTypeInfo.java" contains "import org.apache.flink.api.java.typeutils.GenericTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializerSnapshot.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroFactory.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/GenericRecordAvroTypeInfo.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/utils/AvroKryoSerializerUtils.java" contains "import org.apache.flink.api.java.typeutils.AvroUtils;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/utils/FSDataInputStreamWrapper.java" contains "import org.apache.flink.core.fs.FSDataInputStream;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc-nohive/src/main/java/org/apache/flink/orc/nohive/OrcNoHiveBulkWriterFactory.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc-nohive/src/main/java/org/apache/flink/orc/nohive/OrcNoHiveSplitReaderUtil.java" contains "import org.apache.flink.core.fs.Path;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc-nohive/src/main/java/org/apache/flink/orc/nohive/writer/NoHivePhysicalWriterImpl.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-orc-nohive/src/main/java/org/apache/flink/orc/nohive/shim/OrcNoHiveShim.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFileSystemFormatFactory.java" contains "import org.apache.flink.api.java.typeutils.GenericTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/RowCsvInputFormat.java" contains "import org.apache.flink.api.java.typeutils.RowTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowFormatFactory.java" contains "import org.apache.flink.api.java.typeutils.RowTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowSchemaConverter.java" contains "import org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowSerializationSchema.java" contains "import org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDeserializationSchema.java" contains "import org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvOptions.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/AbstractCsvInputFormat.java" contains "import org.apache.flink.core.fs.FileInputSplit;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataSerializationSchema.java" contains "import org.apache.flink.util.Preconditions;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataDeserializationSchema.java" contains "import org.apache.flink.util.Preconditions;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/writers/NoCompressionBulkWriter.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/writers/HadoopCompressionBulkWriter.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/CompressWriterFactory.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetMapInputFormat.java" contains "import org.apache.flink.api.java.typeutils.MapTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java" contains "import org.apache.flink.api.java.typeutils.RowTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetRowInputFormat.java" contains "import org.apache.flink.api.java.typeutils.ResultTypeQueryable;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetInputFormat.java" contains "import org.apache.flink.api.java.typeutils.RowTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetPojoInputFormat.java" contains "import org.apache.flink.api.java.typeutils.PojoTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetFileSystemFormatFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetWriterFactory.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/PositionOutputStreamAdapter.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/StreamOutputFile.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetBulkWriter.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetSchemaConverter.java" contains "import org.apache.flink.api.java.typeutils.MapTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowConverter.java" contains "import org.apache.flink.api.java.typeutils.MapTypeInfo;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowReadSupport.java" contains "import org.apache.flink.types.Row;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowMaterializer.java" contains "import org.apache.flink.types.Row;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetRecordReader.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriter.java" contains "import org.apache.flink.util.Preconditions;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/row/ParquetRowDataBuilder.java" contains "import org.apache.flink.api.common.serialization.BulkWriter;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/ParquetSplitReaderUtil.java" contains "import org.apache.flink.core.fs.Path;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/ParquetColumnarRowSplitReader.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-sequence-file/src/main/java/org/apache/flink/formats/sequencefile/SequenceFileWriterFactory.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-sequence-file/src/main/java/org/apache/flink/formats/sequencefile/SequenceFileWriter.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/RegistryAvroFormatFactory.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-formats to: flink-core evidence: - file: "flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/RegistryAvroOptions.java" contains "import org.apache.flink.configuration.ConfigOption;"