Package org.apache.iceberg.flink.data

Class StructRowData

  • All Implemented Interfaces:
    org.apache.flink.table.data.RowData
    @Internal
public class StructRowData
extends java.lang.Object
implements org.apache.flink.table.data.RowData

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface org.apache.flink.table.data.RowData

        org.apache.flink.table.data.RowData.FieldGetter

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      int getArity()  
      org.apache.flink.table.data.ArrayData getArray​(int pos)  
      byte[] getBinary​(int pos)  
      boolean getBoolean​(int pos)  
      byte getByte​(int pos)  
      org.apache.flink.table.data.DecimalData getDecimal​(int pos, int precision, int scale)  
      double getDouble​(int pos)  
      float getFloat​(int pos)  
      int getInt​(int pos)  
      long getLong​(int pos)  
      org.apache.flink.table.data.MapData getMap​(int pos)  
      <T> org.apache.flink.table.data.RawValueData<T> getRawValue​(int pos)  
      org.apache.flink.table.data.RowData getRow​(int pos, int numFields)  
      org.apache.flink.types.RowKind getRowKind()  
      short getShort​(int pos)  
      org.apache.flink.table.data.StringData getString​(int pos)  
      org.apache.flink.table.data.TimestampData getTimestamp​(int pos, int precision)  
      boolean isNullAt​(int pos)  
      void setRowKind​(org.apache.flink.types.RowKind newKind)  
      StructRowData setStruct​(StructLike newStruct)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • StructRowData

        public StructRowData​(Types.StructType type,
                     org.apache.flink.types.RowKind kind)

    • Method Detail

      • getArity

        public int getArity()
        Specified by:
        getArity in interface org.apache.flink.table.data.RowData

      • getRowKind

        public org.apache.flink.types.RowKind getRowKind()
        Specified by:
        getRowKind in interface org.apache.flink.table.data.RowData

      • setRowKind

        public void setRowKind​(org.apache.flink.types.RowKind newKind)
        Specified by:
        setRowKind in interface org.apache.flink.table.data.RowData

      • isNullAt

        public boolean isNullAt​(int pos)
        Specified by:
        isNullAt in interface org.apache.flink.table.data.RowData

      • getBoolean

        public boolean getBoolean​(int pos)
        Specified by:
        getBoolean in interface org.apache.flink.table.data.RowData

      • getByte

        public byte getByte​(int pos)
        Specified by:
        getByte in interface org.apache.flink.table.data.RowData

      • getShort

        public short getShort​(int pos)
        Specified by:
        getShort in interface org.apache.flink.table.data.RowData

      • getInt

        public int getInt​(int pos)
        Specified by:
        getInt in interface org.apache.flink.table.data.RowData

      • getLong

        public long getLong​(int pos)
        Specified by:
        getLong in interface org.apache.flink.table.data.RowData

      • getFloat

        public float getFloat​(int pos)
        Specified by:
        getFloat in interface org.apache.flink.table.data.RowData

      • getDouble

        public double getDouble​(int pos)
        Specified by:
        getDouble in interface org.apache.flink.table.data.RowData

      • getString

        public org.apache.flink.table.data.StringData getString​(int pos)
        Specified by:
        getString in interface org.apache.flink.table.data.RowData

      • getDecimal

        public org.apache.flink.table.data.DecimalData getDecimal​(int pos,
                                                          int precision,
                                                          int scale)
        Specified by:
        getDecimal in interface org.apache.flink.table.data.RowData

      • getTimestamp

        public org.apache.flink.table.data.TimestampData getTimestamp​(int pos,
                                                              int precision)
        Specified by:
        getTimestamp in interface org.apache.flink.table.data.RowData

      • getRawValue

        public <T> org.apache.flink.table.data.RawValueData<T> getRawValue​(int pos)
        Specified by:
        getRawValue in interface org.apache.flink.table.data.RowData

      • getBinary

        public byte[] getBinary​(int pos)
        Specified by:
        getBinary in interface org.apache.flink.table.data.RowData

      • getArray

        public org.apache.flink.table.data.ArrayData getArray​(int pos)
        Specified by:
        getArray in interface org.apache.flink.table.data.RowData

      • getMap

        public org.apache.flink.table.data.MapData getMap​(int pos)
        Specified by:
        getMap in interface org.apache.flink.table.data.RowData

      • getRow

        public org.apache.flink.table.data.RowData getRow​(int pos,
                                                  int numFields)
        Specified by:
        getRow in interface org.apache.flink.table.data.RowData