Package org.apache.iceberg.flink.source
Class AvroGenericRecordFileScanTaskReader
- java.lang.Object
-
- org.apache.iceberg.flink.source.AvroGenericRecordFileScanTaskReader
-
- All Implemented Interfaces:
java.io.Serializable
,FileScanTaskReader<org.apache.avro.generic.GenericRecord>
public class AvroGenericRecordFileScanTaskReader extends java.lang.Object implements FileScanTaskReader<org.apache.avro.generic.GenericRecord>
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description AvroGenericRecordFileScanTaskReader(RowDataFileScanTaskReader rowDataReader, RowDataToAvroGenericRecordConverter converter)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CloseableIterator<org.apache.avro.generic.GenericRecord>
open(FileScanTask fileScanTask, InputFilesDecryptor inputFilesDecryptor)
-
-
-
Constructor Detail
-
AvroGenericRecordFileScanTaskReader
public AvroGenericRecordFileScanTaskReader(RowDataFileScanTaskReader rowDataReader, RowDataToAvroGenericRecordConverter converter)
-
-
Method Detail
-
open
public CloseableIterator<org.apache.avro.generic.GenericRecord> open(FileScanTask fileScanTask, InputFilesDecryptor inputFilesDecryptor)
- Specified by:
open
in interfaceFileScanTaskReader<org.apache.avro.generic.GenericRecord>
-
-