Package org.apache.beam.sdk.io.delta

Class SerializableRow

java.lang.Object
org.apache.beam.sdk.io.delta.SerializableRow
All Implemented Interfaces:
Row, Serializable
public class SerializableRow extends Object implements Row, Serializable
A serializable wrapper for Delta Row that implements the Row interface itself, allowing worker nodes to access serialized Row objects using standard Delta Kernel APIs.
See Also:

  • Constructor Details

    • SerializableRow

      public SerializableRow(Row row)

  • Method Details

    • getSchema

      public StructType getSchema()
      Specified by:
      getSchema in interface Row

    • isNullAt

      public boolean isNullAt(int ord)
      Specified by:
      isNullAt in interface Row

    • getBoolean

      public boolean getBoolean(int ord)
      Specified by:
      getBoolean in interface Row

    • getByte

      public byte getByte(int ord)
      Specified by:
      getByte in interface Row

    • getShort

      public short getShort(int ord)
      Specified by:
      getShort in interface Row

    • getInt

      public int getInt(int ord)
      Specified by:
      getInt in interface Row

    • getLong

      public long getLong(int ord)
      Specified by:
      getLong in interface Row

    • getFloat

      public float getFloat(int ord)
      Specified by:
      getFloat in interface Row

    • getDouble

      public double getDouble(int ord)
      Specified by:
      getDouble in interface Row

    • getString

      public String getString(int ord)
      Specified by:
      getString in interface Row

    • getBinary

      public byte[] getBinary(int ord)
      Specified by:
      getBinary in interface Row

    • getDecimal

      public BigDecimal getDecimal(int ord)
      Specified by:
      getDecimal in interface Row

    • getStruct

      public Row getStruct(int ord)
      Specified by:
      getStruct in interface Row

    • getArray

      public ArrayValue getArray(int ord)
      Specified by:
      getArray in interface Row

    • getMap

      public MapValue getMap(int ord)
      Specified by:
      getMap in interface Row

    • equals

      public boolean equals(@Nullable Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object