Package org.apache.iceberg.flink.data

Class FlinkPlannedAvroReader

java.lang.Object

org.apache.iceberg.flink.data.FlinkPlannedAvroReader

All Implemented Interfaces:

org.apache.avro.io.DatumReader<org.apache.flink.table.data.RowData>, SupportsRowPosition

public class FlinkPlannedAvroReader
extends Object
implements org.apache.avro.io.DatumReader<org.apache.flink.table.data.RowData>, SupportsRowPosition

Method Summary

Modifier and Type	Method	Description
static FlinkPlannedAvroReader	create(Schema schema)
static FlinkPlannedAvroReader	create(Schema schema, Map<Integer,?> constants)
org.apache.flink.table.data.RowData	read(org.apache.flink.table.data.RowData reuse, org.apache.avro.io.Decoder decoder)
void	setRowPositionSupplier(Supplier<Long> posSupplier)
void	setSchema(org.apache.avro.Schema fileSchema)

Methods inherited from class java.lang.Object

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

Method Details

create

public static FlinkPlannedAvroReader create(Schema schema)

create

public static FlinkPlannedAvroReader create(Schema schema,
 Map<Integer,?> constants)

setSchema

public void setSchema(org.apache.avro.Schema fileSchema)

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

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)

Specified by:

setRowPositionSupplier in interface SupportsRowPosition