Class ColumnarRow

Object
org.apache.spark.sql.catalyst.InternalRow
org.apache.spark.sql.vectorized.ColumnarRow
All Implemented Interfaces:
Serializable, org.apache.spark.sql.catalyst.expressions.SpecializedGetters

@Evolving public final class ColumnarRow extends org.apache.spark.sql.catalyst.InternalRow
Row abstraction in ColumnVector.
See Also:
  • Constructor Details

    • ColumnarRow

      public ColumnarRow(ColumnVector data, int rowId)
  • Method Details

    • numFields

      public int numFields()
      Specified by:
      numFields in class org.apache.spark.sql.catalyst.InternalRow
    • copy

      public org.apache.spark.sql.catalyst.InternalRow copy()
      Revisit this. This is expensive. This is currently only used in test paths.
      Specified by:
      copy in class org.apache.spark.sql.catalyst.InternalRow
    • anyNull

      public boolean anyNull()
      Overrides:
      anyNull in class org.apache.spark.sql.catalyst.InternalRow
    • isNullAt

      public boolean isNullAt(int ordinal)
    • getBoolean

      public boolean getBoolean(int ordinal)
    • getByte

      public byte getByte(int ordinal)
    • getShort

      public short getShort(int ordinal)
    • getInt

      public int getInt(int ordinal)
    • getLong

      public long getLong(int ordinal)
    • getFloat

      public float getFloat(int ordinal)
    • getDouble

      public double getDouble(int ordinal)
    • getDecimal

      public Decimal getDecimal(int ordinal, int precision, int scale)
    • getUTF8String

      public org.apache.spark.unsafe.types.UTF8String getUTF8String(int ordinal)
    • getBinary

      public byte[] getBinary(int ordinal)
    • getInterval

      public CalendarInterval getInterval(int ordinal)
    • getVariant

      public org.apache.spark.unsafe.types.VariantVal getVariant(int ordinal)
    • getStruct

      public ColumnarRow getStruct(int ordinal, int numFields)
    • getArray

      public ColumnarArray getArray(int ordinal)
    • getMap

      public ColumnarMap getMap(int ordinal)
    • get

      public Object get(int ordinal, DataType dataType)
    • update

      public void update(int ordinal, Object value)
      Specified by:
      update in class org.apache.spark.sql.catalyst.InternalRow
    • setNullAt

      public void setNullAt(int ordinal)
      Specified by:
      setNullAt in class org.apache.spark.sql.catalyst.InternalRow