public class AvroGenericRecordFileScanTaskReader extends java.lang.Object implements FileScanTaskReader<org.apache.avro.generic.GenericRecord>
Constructor and Description |
---|
AvroGenericRecordFileScanTaskReader(RowDataFileScanTaskReader rowDataReader,
RowDataToAvroGenericRecordConverter converter) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<org.apache.avro.generic.GenericRecord> |
open(FileScanTask fileScanTask,
InputFilesDecryptor inputFilesDecryptor) |
public AvroGenericRecordFileScanTaskReader(RowDataFileScanTaskReader rowDataReader, RowDataToAvroGenericRecordConverter converter)
public CloseableIterator<org.apache.avro.generic.GenericRecord> open(FileScanTask fileScanTask, InputFilesDecryptor inputFilesDecryptor)
open
in interface FileScanTaskReader<org.apache.avro.generic.GenericRecord>