org.apache.spark.sql.columnar.compression

Class RunLengthEncoding.Decoder<T extends org.apache.spark.sql.catalyst.types.NativeType>

Object

org.apache.spark.sql.columnar.compression.RunLengthEncoding.Decoder<T>

All Implemented Interfaces:

Decoder<T>

Enclosing class:

RunLengthEncoding

public static class RunLengthEncoding.Decoder<T extends org.apache.spark.sql.catalyst.types.NativeType>
extends Object
implements Decoder<T>

Constructor Summary

Constructors

Constructor and Description
RunLengthEncoding.Decoder(java.nio.ByteBuffer buffer, NativeColumnType<T> columnType)

Method Summary

Methods

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

Methods inherited from class Object

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

Constructor Detail

RunLengthEncoding.Decoder

public RunLengthEncoding.Decoder(java.nio.ByteBuffer buffer,
                         NativeColumnType<T> columnType)

Method Detail

next

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

Specified by:

next in interface Decoder<T extends org.apache.spark.sql.catalyst.types.NativeType>

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Decoder<T extends org.apache.spark.sql.catalyst.types.NativeType>