Package org.apache.hadoop.ozone.container.replication

Class OnDemandContainerReplicationSource

java.lang.Object

org.apache.hadoop.ozone.container.replication.OnDemandContainerReplicationSource

All Implemented Interfaces:

ContainerReplicationSource

public class OnDemandContainerReplicationSource
extends Object
implements ContainerReplicationSource

A naive implementation of the replication source which creates a tar file on-demand without pre-create the compressed archives.

Constructor Summary

Constructors

Constructor	Description
OnDemandContainerReplicationSource(ContainerController controller)

Method Summary

Modifier and Type	Method	Description
void	copyData(long containerId, OutputStream destination, CopyContainerCompression compression)	Copy the container data to an output stream.
void	prepare(long containerId)	Prepare for the replication.

Methods inherited from class java.lang.Object

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

Constructor Details

OnDemandContainerReplicationSource

public OnDemandContainerReplicationSource(ContainerController controller)

Method Details

prepare

public void prepare(long containerId)

Description copied from interface: ContainerReplicationSource

Prepare for the replication.

Specified by:

prepare in interface ContainerReplicationSource

Parameters:

containerId - The name of the container the package.

copyData

public void copyData(long containerId,
 OutputStream destination,
 CopyContainerCompression compression)
              throws IOException

Description copied from interface: ContainerReplicationSource

Copy the container data to an output stream.

Specified by:

copyData in interface ContainerReplicationSource

Parameters:

containerId - Container to replicate

destination - The destination stream to copy all the container data.

compression - Compression algorithm.

Throws:

IOException