Package org.apache.iceberg.flink.data

Class FlinkAvroReader

java.lang.Object
org.apache.iceberg.flink.data.FlinkAvroReader
All Implemented Interfaces:
org.apache.avro.io.DatumReader<org.apache.flink.table.data.RowData>, SupportsRowPosition
@Deprecated public class FlinkAvroReader extends Object implements org.apache.avro.io.DatumReader<org.apache.flink.table.data.RowData>, SupportsRowPosition
Deprecated.
will be removed in 1.8.0; use FlinkPlannedAvroReader instead.

  • Constructor Summary

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

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.flink.table.data.RowData
    read(org.apache.flink.table.data.RowData 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

    • FlinkAvroReader

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

    • FlinkAvroReader

      @Deprecated public FlinkAvroReader(Schema expectedSchema, org.apache.avro.Schema readSchema, Map<Integer,?> constants)
      Deprecated.
      will be removed in 1.8.0; use FlinkPlannedAvroReader 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.flink.table.data.RowData>

    • read

      public org.apache.flink.table.data.RowData read(org.apache.flink.table.data.RowData reuse, org.apache.avro.io.Decoder decoder) throws IOException
      Deprecated.
      Specified by:
      read in interface org.apache.avro.io.DatumReader<org.apache.flink.table.data.RowData>
      Throws:
      IOException

    • setRowPositionSupplier

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