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 and Description
java.io.InputStream	compressedContinuousInputStream(java.io.InputStream s)
java.io.OutputStream	compressedContinuousOutputStream(java.io.OutputStream s)
java.io.InputStream	compressedInputStream(java.io.InputStream s)
java.io.OutputStream	compressedOutputStream(java.io.OutputStream s)

Method Detail

compressedOutputStream

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

compressedContinuousOutputStream

java.io.OutputStream compressedContinuousOutputStream(java.io.OutputStream s)

compressedInputStream

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

compressedContinuousInputStream

java.io.InputStream compressedContinuousInputStream(java.io.InputStream s)