public class LZ4CompressionCodec extends Object implements CompressionCodec
CompressionCodec
.
Block size can be configured by spark.io.compression.lz4.blockSize
.
Constructor and Description |
---|
LZ4CompressionCodec(SparkConf conf) |
Modifier and Type | Method and Description |
---|---|
java.io.InputStream |
compressedInputStream(java.io.InputStream s) |
java.io.OutputStream |
compressedOutputStream(java.io.OutputStream s) |
public LZ4CompressionCodec(SparkConf conf)
public java.io.OutputStream compressedOutputStream(java.io.OutputStream s)
compressedOutputStream
in interface CompressionCodec
public java.io.InputStream compressedInputStream(java.io.InputStream s)
compressedInputStream
in interface CompressionCodec