Package org.apache.iceberg.flink.data

Class RowDataUtil

java.lang.Object
org.apache.iceberg.flink.data.RowDataUtil
public class RowDataUtil extends Object

  • Method Summary

    Modifier and Type
    Method
    Description
    static org.apache.flink.table.data.RowData
    clone(org.apache.flink.table.data.RowData from, org.apache.flink.table.data.RowData reuse, org.apache.flink.table.types.logical.RowType rowType, org.apache.flink.api.common.typeutils.TypeSerializer[] fieldSerializers, org.apache.flink.table.data.RowData.FieldGetter[] fieldGetters)
    Similar to the private RowDataSerializer.copyRowData(RowData, RowData) method.
    static Object
    convertConstant(Type type, Object value)
     

    Methods inherited from class java.lang.Object

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

  • Method Details

    • convertConstant

      public static Object convertConstant(Type type, Object value)

    • clone

      public static org.apache.flink.table.data.RowData clone(org.apache.flink.table.data.RowData from, org.apache.flink.table.data.RowData reuse, org.apache.flink.table.types.logical.RowType rowType, org.apache.flink.api.common.typeutils.TypeSerializer[] fieldSerializers, org.apache.flink.table.data.RowData.FieldGetter[] fieldGetters)
      Similar to the private RowDataSerializer.copyRowData(RowData, RowData) method. This skips the check the arity of rowType and from, because the from RowData may contains additional column for position deletes. Using RowDataSerializer.copy(RowData, RowData) will fail the arity check.