org.apache.spark.io
Class LZFCompressionCodec

Object
  org.apache.spark.io.LZFCompressionCodec

All Implemented Interfaces:

CompressionCodec

public class LZFCompressionCodec
extends Object
implements CompressionCodec

:: DeveloperApi :: LZF implementation of CompressionCodec.

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

LZFCompressionCodec(SparkConf conf)

Method Summary

java.io.InputStream	compressedInputStream(java.io.InputStream s)
java.io.OutputStream	compressedOutputStream(java.io.OutputStream s)

Methods inherited from class Object

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

Constructor Detail

LZFCompressionCodec

public LZFCompressionCodec(SparkConf conf)

Method Detail

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