Developer API

org.apache.spark.io

Class SnappyCompressionCodec

Object

org.apache.spark.io.SnappyCompressionCodec

All Implemented Interfaces:

CompressionCodec

public class SnappyCompressionCodec
extends Object
implements CompressionCodec

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.

Constructor Summary

Constructors

Constructor and Description
SnappyCompressionCodec(SparkConf conf)

Method Summary

Modifier and Type	Method and Description
java.io.InputStream	compressedInputStream(java.io.InputStream s)
java.io.OutputStream	compressedOutputStream(java.io.OutputStream s)
String	version()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SnappyCompressionCodec

public SnappyCompressionCodec(SparkConf conf)

Method Detail

version

public String version()

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