Package org.apache.spark.io

Class ZStdCompressionCodec

Object

org.apache.spark.io.ZStdCompressionCodec

All Implemented Interfaces:

CompressionCodec

public class ZStdCompressionCodec
extends Object
implements CompressionCodec

:: DeveloperApi :: ZStandard implementation of CompressionCodec. For more details see - http://facebook.github.io/zstd/

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
ZStdCompressionCodec(SparkConf conf)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

ZStdCompressionCodec

public ZStdCompressionCodec(SparkConf conf)

Method Details

compressedContinuousInputStream

public InputStream compressedContinuousInputStream(InputStream s)

Specified by:

compressedContinuousInputStream in interface CompressionCodec

compressedInputStream

public InputStream compressedInputStream(InputStream s)

Specified by:

compressedInputStream in interface CompressionCodec

compressedOutputStream

public OutputStream compressedOutputStream(OutputStream s)

Specified by:

compressedOutputStream in interface CompressionCodec