org.apache.spark.sql.columnar.compression

Interface Encoder<T extends org.apache.spark.sql.types.NativeType>

All Known Implementing Classes:

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

public interface Encoder<T extends org.apache.spark.sql.types.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(org.apache.spark.sql.Row row, int ordinal)
int	uncompressedSize()

Method Detail

gatherCompressibilityStats

void gatherCompressibilityStats(org.apache.spark.sql.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)