Package org.apache.spark.io

Interface CompressionCodec

All Known Implementing Classes:

LZ4CompressionCodec, LZFCompressionCodec, SnappyCompressionCodec, ZStdCompressionCodec

public interface CompressionCodec

:: DeveloperApi :: CompressionCodec allows the customization of choosing different compression implementations to be used in block storage.

Note:

The wire protocol for a codec is not guaranteed compatible across versions of Spark. This is intended for use as an internal compression utility within a single Spark application.

Method Summary

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

Method Details

compressedOutputStream

OutputStream compressedOutputStream(OutputStream s)

compressedContinuousOutputStream

OutputStream compressedContinuousOutputStream(OutputStream s)

compressedInputStream

InputStream compressedInputStream(InputStream s)

compressedContinuousInputStream

InputStream compressedContinuousInputStream(InputStream s)