org.apache.spark.io
Class LZ4CompressionCodec
Object
org.apache.spark.io.LZ4CompressionCodec
- All Implemented Interfaces:
- CompressionCodec
public class LZ4CompressionCodec
- extends Object
- implements CompressionCodec
:: DeveloperApi ::
LZ4 implementation of CompressionCodec
.
Block size can be configured by spark.io.compression.lz4.blockSize
.
Note: The wire protocol for this codec is not guaranteed to be compatible across versions
of Spark. This is intended for use as an internal compression utility within a single Spark
application.
Methods inherited from class Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LZ4CompressionCodec
public LZ4CompressionCodec(SparkConf conf)
compressedOutputStream
public java.io.OutputStream compressedOutputStream(java.io.OutputStream s)
- Specified by:
compressedOutputStream
in interface CompressionCodec
compressedInputStream
public java.io.InputStream compressedInputStream(java.io.InputStream s)
- Specified by:
compressedInputStream
in interface CompressionCodec