public static interface AvroUtils.RowReader
| Modifier and Type | Method and Description |
|---|---|
org.apache.spark.sql.avro.AvroDeserializer |
deserializer() |
org.apache.avro.file.FileReader<org.apache.avro.generic.GenericRecord> |
fileReader() |
boolean |
hasNextRow() |
org.apache.spark.sql.catalyst.InternalRow |
nextRow() |
long |
stopPosition() |
org.apache.spark.sql.avro.AvroDeserializer deserializer()
org.apache.avro.file.FileReader<org.apache.avro.generic.GenericRecord> fileReader()
boolean hasNextRow()
org.apache.spark.sql.catalyst.InternalRow nextRow()
long stopPosition()