org.apache.spark.sql.columnar

Class BasicColumnBuilder<T extends org.apache.spark.sql.types.DataType,JvmType>

Object

org.apache.spark.sql.columnar.BasicColumnBuilder<T,JvmType>

All Implemented Interfaces:

ColumnBuilder

Direct Known Subclasses:

ComplexColumnBuilder, NativeColumnBuilder

public class BasicColumnBuilder<T extends org.apache.spark.sql.types.DataType,JvmType>
extends Object
implements ColumnBuilder

Constructor Summary

Constructors

Constructor and Description
BasicColumnBuilder(ColumnStats columnStats, ColumnType<T,JvmType> columnType)

Method Summary

Methods

Modifier and Type	Method and Description
void	appendFrom(org.apache.spark.sql.Row row, int ordinal) Appends row(ordinal) to the column builder.
java.nio.ByteBuffer	build() Returns the final columnar byte buffer.
ColumnStats	columnStats() Column statistics information
ColumnType<T,JvmType>	columnType()
void	initialize(int initialSize, String columnName, boolean useCompression) Initializes with an approximate lower bound on the expected number of elements in this column.

Methods inherited from class Object

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

Constructor Detail

BasicColumnBuilder

public BasicColumnBuilder(ColumnStats columnStats,
                  ColumnType<T,JvmType> columnType)

Method Detail

columnStats

public ColumnStats columnStats()

Description copied from interface: ColumnBuilder

Column statistics information

Specified by:

columnStats in interface ColumnBuilder

columnType

public ColumnType<T,JvmType> columnType()

initialize

public void initialize(int initialSize,
              String columnName,
              boolean useCompression)

Description copied from interface: ColumnBuilder

Initializes with an approximate lower bound on the expected number of elements in this column.

Specified by:

initialize in interface ColumnBuilder

appendFrom

public void appendFrom(org.apache.spark.sql.Row row,
              int ordinal)

Description copied from interface: ColumnBuilder

Appends row(ordinal) to the column builder.

Specified by:

appendFrom in interface ColumnBuilder

build

public java.nio.ByteBuffer build()

Description copied from interface: ColumnBuilder

Returns the final columnar byte buffer.

Specified by:

build in interface ColumnBuilder