alluxio.util.compression

Class GzipMarshaller

java.lang.Object

alluxio.util.compression.GzipMarshaller

All Implemented Interfaces:

DirectoryMarshaller

public class GzipMarshaller
extends Object
implements DirectoryMarshaller

Applies a simple Gzip compression to the NoCompressionMarshaller.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.util.compression.DirectoryMarshaller

DirectoryMarshaller.Factory, DirectoryMarshaller.Type

Constructor Summary

Constructors

Constructor and Description
GzipMarshaller()

Method Summary

Modifier and Type	Method and Description
long	read(Path path, InputStream inputStream) Reads the content from the inputStream and writes them to the specified path.
long	write(Path path, OutputStream outputStream) Writes the contents of path ot outputStream such that it can be read by DirectoryMarshaller.read(Path, InputStream).

Methods inherited from class java.lang.Object

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

Constructor Detail

GzipMarshaller

public GzipMarshaller()

Method Detail

write

public long write(Path path,
                  OutputStream outputStream)
           throws IOException,
                  InterruptedException

Description copied from interface: DirectoryMarshaller

Writes the contents of path ot outputStream such that it can be read by DirectoryMarshaller.read(Path, InputStream).

Specified by:

write in interface DirectoryMarshaller

Parameters:

path - the directory to marshall

outputStream - the output stream that the marshalled information

Returns:

the number of bytes read in path

Throws:

IOException

InterruptedException

read

public long read(Path path,
                 InputStream inputStream)
          throws IOException

Description copied from interface: DirectoryMarshaller

Reads the content from the inputStream and writes them to the specified path.

Specified by:

read in interface DirectoryMarshaller

Parameters:

path - the output path

inputStream - the stream to read the data from

Returns:

the number of bytes written to path

Throws:

IOException