Packages

c

org.apache.spark.io

SnappyCompressionCodec

class SnappyCompressionCodec extends CompressionCodec

Developer API

Snappy implementation of org.apache.spark.io.CompressionCodec. Block size can be configured by spark.io.compression.snappy.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. SnappyCompressionCodec
  2. CompressionCodec
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SnappyCompressionCodec(conf: SparkConf)

Value Members

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