alluxio.util

Class ParallelZipUtils

java.lang.Object

alluxio.util.ParallelZipUtils

public class ParallelZipUtils
extends Object

Utility methods for working with parallel zip archives.

Method Summary

Modifier and Type	Method and Description
static void	compress(Path dirPath, OutputStream outputStream, int poolSize, int compressionLevel) Creates a zipped archive from the given path in parallel, streaming the data to the give output stream.
static void	decompress(Path dirPath, String backupPath, int poolSize) Reads a zipped archive from a path in parallel and writes it to the given path.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

compress

public static void compress(Path dirPath,
                            OutputStream outputStream,
                            int poolSize,
                            int compressionLevel)
                     throws IOException,
                            InterruptedException

Creates a zipped archive from the given path in parallel, streaming the data to the give output stream.

Parameters:

dirPath -

outputStream -

poolSize -

compressionLevel -

Throws:

IOException

InterruptedException

decompress

public static void decompress(Path dirPath,
                              String backupPath,
                              int poolSize)
                       throws IOException

Reads a zipped archive from a path in parallel and writes it to the given path.

Parameters:

dirPath -

backupPath -

poolSize -

Throws:

IOException