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