Package io.delta.kernel.defaults.internal.data

Class DefaultRowBasedColumnarBatch

Object
io.delta.kernel.defaults.internal.data.DefaultRowBasedColumnarBatch
All Implemented Interfaces:
io.delta.kernel.data.ColumnarBatch
public class DefaultRowBasedColumnarBatch extends Object implements io.delta.kernel.data.ColumnarBatch
ColumnarBatch wrapper around list of Row objects. TODO: We should change the DefaultJsonHandler to generate data in true columnar format than wrapping a set of rows with a columnar batch interface.

  • Constructor Summary

    Constructors
    Constructor
    Description
    DefaultRowBasedColumnarBatch(io.delta.kernel.types.StructType schema, List<io.delta.kernel.data.Row> rows)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.delta.kernel.data.ColumnVector
    getColumnVector(int ordinal)
     
    io.delta.kernel.types.StructType
    getSchema()
     
    int
    getSize()
     
    io.delta.kernel.data.ColumnarBatch
    withDeletedColumnAt(int ordinal)
    TODO this implementation sucks
    io.delta.kernel.data.ColumnarBatch
    withNewColumn(int ordinal, io.delta.kernel.types.StructField columnSchema, io.delta.kernel.data.ColumnVector columnVector)
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.delta.kernel.data.ColumnarBatch

    getRows, withNewSchema

  • Constructor Details

    • DefaultRowBasedColumnarBatch

      public DefaultRowBasedColumnarBatch(io.delta.kernel.types.StructType schema, List<io.delta.kernel.data.Row> rows)

  • Method Details

    • getSchema

      public io.delta.kernel.types.StructType getSchema()
      Specified by:
      getSchema in interface io.delta.kernel.data.ColumnarBatch

    • getSize

      public int getSize()
      Specified by:
      getSize in interface io.delta.kernel.data.ColumnarBatch

    • getColumnVector

      public io.delta.kernel.data.ColumnVector getColumnVector(int ordinal)
      Specified by:
      getColumnVector in interface io.delta.kernel.data.ColumnarBatch

    • withNewColumn

      public io.delta.kernel.data.ColumnarBatch withNewColumn(int ordinal, io.delta.kernel.types.StructField columnSchema, io.delta.kernel.data.ColumnVector columnVector)
      Specified by:
      withNewColumn in interface io.delta.kernel.data.ColumnarBatch

    • withDeletedColumnAt

      public io.delta.kernel.data.ColumnarBatch withDeletedColumnAt(int ordinal)
      TODO this implementation sucks
      Specified by:
      withDeletedColumnAt in interface io.delta.kernel.data.ColumnarBatch