Package 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.

Constructor Summary

Constructors

Constructor	Description
LZ4CompressionCodec(SparkConf conf)

Method Summary

Modifier and Type	Method	Description
InputStream	compressedInputStream(InputStream s)
OutputStream	compressedOutputStream(OutputStream s)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.spark.io.CompressionCodec

compressedContinuousInputStream, compressedContinuousOutputStream

Constructor Details

LZ4CompressionCodec

public LZ4CompressionCodec(SparkConf conf)

Method Details

compressedInputStream

public InputStream compressedInputStream(InputStream s)

Specified by:

compressedInputStream in interface CompressionCodec

compressedOutputStream

public OutputStream compressedOutputStream(OutputStream s)

Specified by:

compressedOutputStream in interface CompressionCodec