Class ColumnarBatchRow

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

@DeveloperApi public final class ColumnarBatchRow extends org.apache.spark.sql.catalyst.InternalRow
This class wraps an array of ColumnVector and provides a row view.
Since:
3.3.0
See Also:
  • Field Details

    • rowId

      public int rowId
  • Constructor Details

    • ColumnarBatchRow

      public ColumnarBatchRow(ColumnVector[] columns)
  • 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()
      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)
    • 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