Package org.apache.iceberg.flink.data

Class RowDataProjection

  • All Implemented Interfaces:
    org.apache.flink.table.data.RowData
    public class RowDataProjection
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 Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      static RowDataProjection create​(org.apache.flink.table.types.logical.RowType rowType, Types.StructType schema, Types.StructType projectedSchema)
      Creates a projecting wrapper for RowData rows.
      static RowDataProjection create​(Schema schema, Schema projectedSchema)
      Creates a projecting wrapper for RowData rows.
      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 kind)  
      org.apache.flink.table.data.RowData wrap​(org.apache.flink.table.data.RowData row)  

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • create

        public static RowDataProjection create​(Schema schema,
                                       Schema projectedSchema)
        Creates a projecting wrapper for RowData rows.

        This projection will not project the nested children types of repeated types like lists and maps.

        Parameters:
        schema - schema of rows wrapped by this projection
        projectedSchema - result schema of the projected rows
        Returns:
        a wrapper to project rows

      • create

        public static RowDataProjection create​(org.apache.flink.table.types.logical.RowType rowType,
                                       Types.StructType schema,
                                       Types.StructType projectedSchema)
        Creates a projecting wrapper for RowData rows.

        This projection will not project the nested children types of repeated types like lists and maps.

        Parameters:
        rowType - flink row type of rows wrapped by this projection
        schema - schema of rows wrapped by this projection
        projectedSchema - result schema of the projected rows
        Returns:
        a wrapper to project rows

      • wrap

        public org.apache.flink.table.data.RowData wrap​(org.apache.flink.table.data.RowData row)

      • 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 kind)
        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