Package org.apache.iceberg.flink.data

Class RowDataUtil

  • public class RowDataUtil
extends java.lang.Object

    • Method Summary

      All Methods Static Methods Concrete Methods 
      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)
      Similar to the private RowDataSerializer.copyRowData(RowData, RowData) method.
      static java.lang.Object convertConstant​(Type type, java.lang.Object value)  

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • convertConstant

        public static java.lang.Object convertConstant​(Type type,
                                               java.lang.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)
        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.