org.apache.spark.io
Class SnappyCompressionCodec
Object
org.apache.spark.io.SnappyCompressionCodec
- All Implemented Interfaces:
- CompressionCodec
public class SnappyCompressionCodec
- extends Object
- implements CompressionCodec
:: DeveloperApi ::
Snappy implementation of CompressionCodec
.
Block size can be configured by spark.io.compression.snappy.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 |
SnappyCompressionCodec
public SnappyCompressionCodec(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