org.apache.spark.sql.columnar.compression

Interface Encoder<T extends NativeType>

All Known Implementing Classes:

BooleanBitSet.Encoder, DictionaryEncoding.Encoder, IntDelta.Encoder, LongDelta.Encoder, PassThrough.Encoder, RunLengthEncoding.Encoder

public interface Encoder<T extends NativeType>

Method Summary

Methods

Modifier and Type	Method and Description
java.nio.ByteBuffer	compress(java.nio.ByteBuffer from, java.nio.ByteBuffer to)
int	compressedSize()
double	compressionRatio()
void	gatherCompressibilityStats(Row row, int ordinal)
int	uncompressedSize()

Method Detail

gatherCompressibilityStats

void gatherCompressibilityStats(Row row,
                              int ordinal)

compressedSize

int compressedSize()

uncompressedSize

int uncompressedSize()

compressionRatio

double compressionRatio()

compress

java.nio.ByteBuffer compress(java.nio.ByteBuffer from,
                           java.nio.ByteBuffer to)