public class AvroBulkFormat extends Object implements FormatReaderFactory
FormatReaderFactory
for Avro records.FormatReaderFactory.Context
Modifier and Type | Field and Description |
---|---|
protected RowType |
projectedRowType |
Constructor and Description |
---|
AvroBulkFormat(RowType projectedRowType) |
Modifier and Type | Method and Description |
---|---|
RecordReader<InternalRow> |
createReader(FormatReaderFactory.Context context) |
protected final RowType projectedRowType
public AvroBulkFormat(RowType projectedRowType)
public RecordReader<InternalRow> createReader(FormatReaderFactory.Context context) throws IOException
createReader
in interface FormatReaderFactory
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.