public class SnappyCompressionCodec extends Object implements CompressionCodec
CompressionCodec. Block size can be configured by
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.
|Modifier and Type||Method and Description|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public SnappyCompressionCodec(SparkConf conf)
public java.io.OutputStream compressedOutputStream(java.io.OutputStream s)