Packages

c

org.apache.spark.io

ZStdCompressionCodec

class ZStdCompressionCodec extends CompressionCodec

Developer API

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

Annotations
@DeveloperApi()
Source
CompressionCodec.scala
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.

Linear Supertypes
CompressionCodec, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ZStdCompressionCodec
  2. CompressionCodec
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ZStdCompressionCodec(conf: SparkConf)

Value Members

  1. def compressedContinuousInputStream(s: InputStream): InputStream
    Definition Classes
    ZStdCompressionCodec → CompressionCodec
  2. def compressedInputStream(s: InputStream): InputStream
    Definition Classes
    ZStdCompressionCodec → CompressionCodec
  3. def compressedOutputStream(s: OutputStream): OutputStream
    Definition Classes
    ZStdCompressionCodec → CompressionCodec