org.apache.spark.sql.columnar.compression

Class RunLengthEncoding

Object

org.apache.spark.sql.columnar.compression.RunLengthEncoding

All Implemented Interfaces:

java.io.Serializable, CompressionScheme, scala.Equals, scala.Product

public class RunLengthEncoding
extends Object
implements CompressionScheme, scala.Product, scala.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RunLengthEncoding.Decoder<T extends org.apache.spark.sql.catalyst.types.NativeType>
static class	RunLengthEncoding.Encoder<T extends org.apache.spark.sql.catalyst.types.NativeType>

Constructor Summary

Constructors

Constructor and Description
RunLengthEncoding()

Method Summary

Methods

Modifier and Type	Method and Description
static <T extends org.apache.spark.sql.catalyst.types.NativeType> RunLengthEncoding.Decoder<T>	decoder(java.nio.ByteBuffer buffer, NativeColumnType<T> columnType)
static <T extends org.apache.spark.sql.catalyst.types.NativeType> RunLengthEncoding.Encoder<T>	encoder(NativeColumnType<T> columnType)
static boolean	supports(ColumnType<?,?> columnType)
static int	typeId()

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.sql.columnar.compression.CompressionScheme

decoder, encoder, supports, typeId

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

RunLengthEncoding

public RunLengthEncoding()

Method Detail

typeId

public static int typeId()

encoder

public static <T extends org.apache.spark.sql.catalyst.types.NativeType> RunLengthEncoding.Encoder<T> encoder(NativeColumnType<T> columnType)

decoder

public static <T extends org.apache.spark.sql.catalyst.types.NativeType> RunLengthEncoding.Decoder<T> decoder(java.nio.ByteBuffer buffer,
                                                                                              NativeColumnType<T> columnType)

supports

public static boolean supports(ColumnType<?,?> columnType)