RowConverter

java.lang.Object

org.apache.iceberg.flink.source.reader.RowConverter

All Implemented Interfaces:: Serializable, Function<org.apache.flink.table.data.RowData,org.apache.flink.types.Row>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.types.Row>, RowDataConverter<org.apache.flink.types.Row>

public class RowConverter extends Object implements RowDataConverter<org.apache.flink.types.Row>

See Also:

Serialized Form

Method Summary

Modifier and Type

Method

Description

org.apache.flink.types.Row

apply(org.apache.flink.table.data.RowData rowData)

static RowConverter

fromIcebergSchema(Schema icebergSchema)

org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row>

getProducedType()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Function
andThen, compose

Method Details
- fromIcebergSchema
  
  public static RowConverter fromIcebergSchema(Schema icebergSchema)
- apply
  
  public org.apache.flink.types.Row apply(org.apache.flink.table.data.RowData rowData)
  
  Specified by:
  
  apply in interface Function<org.apache.flink.table.data.RowData,org.apache.flink.types.Row>
- getProducedType
  
  public org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> getProducedType()
  
  Specified by:
  
  getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.types.Row>