public class PassThrough extends Object implements CompressionScheme, scala.Product, scala.Serializable
Modifier and Type | Class and Description |
---|---|
static class |
PassThrough.Decoder<T extends org.apache.spark.sql.catalyst.types.NativeType> |
static class |
PassThrough.Encoder<T extends org.apache.spark.sql.catalyst.types.NativeType> |
Constructor and Description |
---|
PassThrough() |
Modifier and Type | Method and Description |
---|---|
static <T extends org.apache.spark.sql.catalyst.types.NativeType> |
decoder(java.nio.ByteBuffer buffer,
NativeColumnType<T> columnType) |
static <T extends org.apache.spark.sql.catalyst.types.NativeType> |
encoder(NativeColumnType<T> columnType) |
static boolean |
supports(ColumnType<?,?> columnType) |
static int |
typeId() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decoder, encoder, supports, typeId
public static int typeId()
public static boolean supports(ColumnType<?,?> columnType)
public static <T extends org.apache.spark.sql.catalyst.types.NativeType> PassThrough.Encoder<T> encoder(NativeColumnType<T> columnType)
public static <T extends org.apache.spark.sql.catalyst.types.NativeType> PassThrough.Decoder<T> decoder(java.nio.ByteBuffer buffer, NativeColumnType<T> columnType)