org.apache.spark.sql.columnar

Class BasicColumnAccessor<T extends DataType,JvmType>

Object

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

All Implemented Interfaces:

ColumnAccessor

Direct Known Subclasses:

BinaryColumnAccessor, GenericColumnAccessor, NativeColumnAccessor

public abstract class BasicColumnAccessor<T extends DataType,JvmType>
extends Object
implements ColumnAccessor

Constructor Summary

Constructors

Constructor and Description
BasicColumnAccessor(java.nio.ByteBuffer buffer, ColumnType<T,JvmType> columnType)

Method Summary

Methods

Modifier and Type	Method and Description
void	extractSingle(org.apache.spark.sql.catalyst.expressions.MutableRow row, int ordinal)
void	extractTo(org.apache.spark.sql.catalyst.expressions.MutableRow row, int ordinal)
boolean	hasNext()

Methods inherited from class Object

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

Constructor Detail

BasicColumnAccessor

public BasicColumnAccessor(java.nio.ByteBuffer buffer,
                   ColumnType<T,JvmType> columnType)

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface ColumnAccessor

extractTo

public void extractTo(org.apache.spark.sql.catalyst.expressions.MutableRow row,
             int ordinal)

Specified by:

extractTo in interface ColumnAccessor

extractSingle

public void extractSingle(org.apache.spark.sql.catalyst.expressions.MutableRow row,
                 int ordinal)