Package org.apache.hadoop.ozone.container.keyvalue

Class TarContainerPacker

java.lang.Object

org.apache.hadoop.ozone.container.keyvalue.TarContainerPacker

All Implemented Interfaces:

ContainerPacker<KeyValueContainerData>

public class TarContainerPacker
extends Object
implements ContainerPacker<KeyValueContainerData>

Compress/uncompress KeyValueContainer data to a tar archive.

Constructor Summary

Constructors

Constructor	Description
TarContainerPacker(CopyContainerCompression compression)

Method Summary

Modifier and Type	Method	Description
static Path	getChunkPath(Path baseDir)
static Path	getDbPath(Path baseDir, KeyValueContainerData containerData)
static Path	getDbPath(KeyValueContainerData containerData)
void	pack(Container<KeyValueContainerData> container, OutputStream output)	Given a containerData include all the required container data/metadata in a tar file.
byte[]	unpackContainerData(Container<KeyValueContainerData> container, InputStream input, Path tmpDir, Path destContainerDir)	Given an input stream (tar file) extract the data to the specified directories.
byte[]	unpackContainerDescriptor(InputStream input)	Read the descriptor from the finished archive to get the data before importing the container.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.ozone.container.common.interfaces.ContainerPacker

persistCustomContainerState

Constructor Details

TarContainerPacker

public TarContainerPacker(CopyContainerCompression compression)

Method Details

unpackContainerData

public byte[] unpackContainerData(Container<KeyValueContainerData> container,
 InputStream input,
 Path tmpDir,
 Path destContainerDir)
                           throws IOException

Given an input stream (tar file) extract the data to the specified directories.

Specified by:

unpackContainerData in interface ContainerPacker<KeyValueContainerData>

Parameters:

container - container which defines the destination structure.

input - the input stream.

Returns:

the byte content of the descriptor (which won't be written to a file but returned).

Throws:

IOException

pack

public void pack(Container<KeyValueContainerData> container,
 OutputStream output)
          throws IOException

Given a containerData include all the required container data/metadata in a tar file.

Specified by:

pack in interface ContainerPacker<KeyValueContainerData>

Parameters:

container - Container to archive (data + metadata).

output - Destination tar file/stream.

Throws:

IOException

unpackContainerDescriptor

public byte[] unpackContainerDescriptor(InputStream input)
                                 throws IOException

Description copied from interface: ContainerPacker

Read the descriptor from the finished archive to get the data before importing the container.

Specified by:

unpackContainerDescriptor in interface ContainerPacker<KeyValueContainerData>

Throws:

IOException

getDbPath

public static Path getDbPath(KeyValueContainerData containerData)

getDbPath

public static Path getDbPath(Path baseDir,
 KeyValueContainerData containerData)

getChunkPath

public static Path getChunkPath(Path baseDir)