org.apache.spark.sql.columnar.compression

Class DictionaryEncoding

Object

org.apache.spark.sql.columnar.compression.DictionaryEncoding

All Implemented Interfaces:

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

public class DictionaryEncoding
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	DictionaryEncoding.Decoder<T extends org.apache.spark.sql.catalyst.types.NativeType>
static class	DictionaryEncoding.Encoder<T extends org.apache.spark.sql.catalyst.types.NativeType>

Constructor Summary

Constructors

Constructor and Description
DictionaryEncoding()

Method Summary

Methods

Modifier and Type	Method and Description
static <T extends org.apache.spark.sql.catalyst.types.NativeType> DictionaryEncoding.Decoder<T>	decoder(java.nio.ByteBuffer buffer, NativeColumnType<T> columnType)
static <T extends org.apache.spark.sql.catalyst.types.NativeType> DictionaryEncoding.Encoder<T>	encoder(NativeColumnType<T> columnType)
static short	MAX_DICT_SIZE()
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

DictionaryEncoding

public DictionaryEncoding()

Method Detail

typeId

public static int typeId()

MAX_DICT_SIZE

public static short MAX_DICT_SIZE()

decoder

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

encoder

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

supports

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