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 java.lang.Object implements org.apache.avro.io.DatumReader<org.apache.flink.table.data.RowData>, SupportsRowPosition
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static FlinkPlannedAvroReader
create(Schema schema)
static FlinkPlannedAvroReader
create(Schema schema, java.util.Map<java.lang.Integer,?> constants)
org.apache.flink.table.data.RowData
read(org.apache.flink.table.data.RowData reuse, org.apache.avro.io.Decoder decoder)
void
setRowPositionSupplier(java.util.function.Supplier<java.lang.Long> posSupplier)
void
setSchema(org.apache.avro.Schema fileSchema)
-
-
-
Method Detail
-
create
public static FlinkPlannedAvroReader create(Schema schema)
-
create
public static FlinkPlannedAvroReader create(Schema schema, java.util.Map<java.lang.Integer,?> constants)
-
setSchema
public void setSchema(org.apache.avro.Schema fileSchema)
- Specified by:
setSchema
in interfaceorg.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 java.io.IOException
- Specified by:
read
in interfaceorg.apache.avro.io.DatumReader<org.apache.flink.table.data.RowData>
- Throws:
java.io.IOException
-
setRowPositionSupplier
public void setRowPositionSupplier(java.util.function.Supplier<java.lang.Long> posSupplier)
- Specified by:
setRowPositionSupplier
in interfaceSupportsRowPosition
-
-