diff options
| author | Reynold Xin <rxin@apache.org> | 2014-07-15 01:46:57 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-07-15 01:46:57 -0700 |
| commit | dd95abada78b4d0aec97dacda50fdfd74464b073 (patch) | |
| tree | 823d5955b61420b64144dbf7fabee893492c1f13 /core/src/test | |
| parent | 7446f5ff93142d2dd5c79c63fa947f47a1d4db8b (diff) | |
| download | spark-dd95abada78b4d0aec97dacda50fdfd74464b073.tar.gz spark-dd95abada78b4d0aec97dacda50fdfd74464b073.tar.bz2 spark-dd95abada78b4d0aec97dacda50fdfd74464b073.zip | |
[SPARK-2399] Add support for LZ4 compression.
Based on Greg Bowyer's patch from JIRA https://issues.apache.org/jira/browse/SPARK-2399
Author: Reynold Xin <rxin@apache.org>
Closes #1416 from rxin/lz4 and squashes the following commits:
6c8fefe [Reynold Xin] Fixed typo.
8a14d38 [Reynold Xin] [SPARK-2399] Add support for LZ4 compression.
Diffstat (limited to 'core/src/test')
| -rw-r--r-- | core/src/test/scala/org/apache/spark/io/CompressionCodecSuite.scala | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/core/src/test/scala/org/apache/spark/io/CompressionCodecSuite.scala b/core/src/test/scala/org/apache/spark/io/CompressionCodecSuite.scala index 68a0ea36aa..42fc395fa6 100644 --- a/core/src/test/scala/org/apache/spark/io/CompressionCodecSuite.scala +++ b/core/src/test/scala/org/apache/spark/io/CompressionCodecSuite.scala @@ -50,6 +50,12 @@ class CompressionCodecSuite extends FunSuite { testCodec(codec) } + test("lz4 compression codec") { + val codec = CompressionCodec.createCodec(conf, classOf[LZ4CompressionCodec].getName) + assert(codec.getClass === classOf[LZ4CompressionCodec]) + testCodec(codec) + } + test("lzf compression codec") { val codec = CompressionCodec.createCodec(conf, classOf[LZFCompressionCodec].getName) assert(codec.getClass === classOf[LZFCompressionCodec]) |