org.apache.spark.sql.columnar.compression

Interface CompressionScheme

All Known Implementing Classes:

BooleanBitSet, DictionaryEncoding, IntDelta, LongDelta, PassThrough, RunLengthEncoding

public interface CompressionScheme

Method Summary

Methods

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

Method Detail

typeId

int typeId()

supports

boolean supports(ColumnType<?,?> columnType)

encoder

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

decoder

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