Package org.apache.iceberg.flink

Class RowDataWrapper

java.lang.Object
org.apache.iceberg.flink.RowDataWrapper
All Implemented Interfaces:
StructLike
public class RowDataWrapper extends Object implements StructLike

  • Constructor Details

    • RowDataWrapper

      public RowDataWrapper(org.apache.flink.table.types.logical.RowType rowType, Types.StructType struct)

  • Method Details

    • wrap

      public RowDataWrapper wrap(org.apache.flink.table.data.RowData data)

    • size

      public int size()
      Specified by:
      size in interface StructLike

    • get

      public <T> T get(int pos, Class<T> javaClass)
      Specified by:
      get in interface StructLike

    • set

      public <T> void set(int pos, T value)
      Specified by:
      set in interface StructLike