org.apache.spark.sql.columnar.compression

Interface CompressibleColumnAccessor<T extends org.apache.spark.sql.types.NativeType>

All Superinterfaces:

ColumnAccessor

All Known Implementing Classes:

BooleanColumnAccessor, ByteColumnAccessor, DateColumnAccessor, DoubleColumnAccessor, FloatColumnAccessor, IntColumnAccessor, LongColumnAccessor, NativeColumnAccessor, ShortColumnAccessor, StringColumnAccessor, TimestampColumnAccessor

public interface CompressibleColumnAccessor<T extends org.apache.spark.sql.types.NativeType>
extends ColumnAccessor

Method Summary

Methods

Modifier and Type	Method and Description
Decoder<T>	decoder()
void	extractSingle(org.apache.spark.sql.catalyst.expressions.MutableRow row, int ordinal)
boolean	hasNext()
void	initialize()

Methods inherited from interface org.apache.spark.sql.columnar.ColumnAccessor

extractTo, underlyingBuffer

Method Detail

decoder

Decoder<T> decoder()

initialize

void initialize()

Specified by:

initialize in interface ColumnAccessor

hasNext

boolean hasNext()

Specified by:

hasNext in interface ColumnAccessor

extractSingle

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