Packages

c

org.apache.spark.io

LZ4CompressionCodec

class LZ4CompressionCodec extends CompressionCodec

Developer API

LZ4 implementation of org.apache.spark.io.CompressionCodec. Block size can be configured by spark.io.compression.lz4.blockSize.

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. LZ4CompressionCodec
  2. CompressionCodec
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new LZ4CompressionCodec(conf: SparkConf)

Value Members

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