Package org.apache.iceberg.spark.data

Class SparkAvroReader

java.lang.Object
org.apache.iceberg.spark.data.SparkAvroReader
All Implemented Interfaces:
org.apache.avro.io.DatumReader<org.apache.spark.sql.catalyst.InternalRow>, SupportsRowPosition
@Deprecated public class SparkAvroReader extends Object implements org.apache.avro.io.DatumReader<org.apache.spark.sql.catalyst.InternalRow>, SupportsRowPosition
Deprecated.
will be removed in 1.8.0; use SparkPlannedAvroReader instead.

  • Constructor Summary

    Constructors
    Constructor
    Description
    SparkAvroReader(Schema expectedSchema, org.apache.avro.Schema readSchema)
    Deprecated.
    will be removed in 1.8.0; use SparkPlannedAvroReader instead.
    SparkAvroReader(Schema expectedSchema, org.apache.avro.Schema readSchema, Map<Integer,?> constants)
    Deprecated.
    will be removed in 1.8.0; use SparkPlannedAvroReader instead.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.spark.sql.catalyst.InternalRow
    read(org.apache.spark.sql.catalyst.InternalRow reuse, org.apache.avro.io.Decoder decoder)
    Deprecated.
     
    void
    setRowPositionSupplier(Supplier<Long> posSupplier)
    Deprecated.
     
    void
    setSchema(org.apache.avro.Schema newFileSchema)
    Deprecated.
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • SparkAvroReader

      @Deprecated public SparkAvroReader(Schema expectedSchema, org.apache.avro.Schema readSchema)
      Deprecated.
      will be removed in 1.8.0; use SparkPlannedAvroReader instead.

    • SparkAvroReader

      @Deprecated public SparkAvroReader(Schema expectedSchema, org.apache.avro.Schema readSchema, Map<Integer,?> constants)
      Deprecated.
      will be removed in 1.8.0; use SparkPlannedAvroReader instead.

  • Method Details

    • setSchema

      public void setSchema(org.apache.avro.Schema newFileSchema)
      Deprecated.
      Specified by:
      setSchema in interface org.apache.avro.io.DatumReader<org.apache.spark.sql.catalyst.InternalRow>

    • read

      public org.apache.spark.sql.catalyst.InternalRow read(org.apache.spark.sql.catalyst.InternalRow reuse, org.apache.avro.io.Decoder decoder) throws IOException
      Deprecated.
      Specified by:
      read in interface org.apache.avro.io.DatumReader<org.apache.spark.sql.catalyst.InternalRow>
      Throws:
      IOException

    • setRowPositionSupplier

      public void setRowPositionSupplier(Supplier<Long> posSupplier)
      Deprecated.
      Specified by:
      setRowPositionSupplier in interface SupportsRowPosition