Package org.apache.spark.sql.avro

Interface AvroUtils.RowReader

Enclosing class:
AvroUtils
public static interface AvroUtils.RowReader

  • Method Summary

    Modifier and Type
    Method
    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()
     

  • Method Details

    • deserializer

      org.apache.spark.sql.avro.AvroDeserializer deserializer()

    • fileReader

      org.apache.avro.file.FileReader<org.apache.avro.generic.GenericRecord> fileReader()

    • hasNextRow

      boolean hasNextRow()

    • nextRow

      org.apache.spark.sql.catalyst.InternalRow nextRow()

    • stopPosition

      long stopPosition()