org.apache.spark.sql.columnar

Class ByteArrayColumnType<T extends org.apache.spark.sql.types.DataType>

Object

org.apache.spark.sql.columnar.ColumnType<T,byte[]>

org.apache.spark.sql.columnar.ByteArrayColumnType<T>

Direct Known Subclasses:

BINARY, GENERIC

public abstract class ByteArrayColumnType<T extends org.apache.spark.sql.types.DataType>
extends ColumnType<T,byte[]>

Constructor Summary

Constructors

Constructor and Description
ByteArrayColumnType(int typeId, int defaultSize)

Method Summary

Methods

Modifier and Type	Method and Description
int	actualSize(org.apache.spark.sql.Row row, int ordinal) Returns the size of the value row(ordinal).
void	append(byte[] v, java.nio.ByteBuffer buffer) Appends the given value v of type T into the given ByteBuffer.
byte[]	extract(java.nio.ByteBuffer buffer) Extracts a value out of the buffer at the buffer's current position.

Methods inherited from class org.apache.spark.sql.columnar.ColumnType

append, apply, clone, copyField, defaultSize, extract, getField, setField, toString, typeId

Methods inherited from class Object

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

Constructor Detail

ByteArrayColumnType

public ByteArrayColumnType(int typeId,
                   int defaultSize)

Method Detail

actualSize

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

Description copied from class: ColumnType

Returns the size of the value row(ordinal). This is used to calculate the size of variable length types such as byte arrays and strings.

Overrides:

actualSize in class ColumnType<T extends org.apache.spark.sql.types.DataType,byte[]>

append

public void append(byte[] v,
          java.nio.ByteBuffer buffer)

Description copied from class: ColumnType

Appends the given value v of type T into the given ByteBuffer.

Specified by:

append in class ColumnType<T extends org.apache.spark.sql.types.DataType,byte[]>

extract

public byte[] extract(java.nio.ByteBuffer buffer)

Description copied from class: ColumnType

Extracts a value out of the buffer at the buffer's current position.

Specified by:

extract in class ColumnType<T extends org.apache.spark.sql.types.DataType,byte[]>