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

package org.apache.hadoop.ozone.container.replication

Classes to replicate container data between datanodes.

Class	Description
AbstractReplicationTask	Abstract class to capture common variables and methods for different types of replication tasks.
AbstractReplicationTask.Status	ENUM representing the different status values a replication task can have.
ContainerDownloader	Service to download container data from other datanodes.
ContainerImporter	Imports container from tarball.
ContainerReplicationSource	Contract to prepare provide the container in binary form..
ContainerReplicator	Service to do the real replication task.
ContainerUploader	Client-side interface for sending a container to a target datanode.
CopyContainerCompression	Defines compression algorithm for container replication.
DownloadAndImportReplicator	Default replication implementation.
GrpcContainerUploader	Uploads container to target datanode via gRPC.
GrpcContainerUploader.SendContainerResponseStreamObserver	Observes gRPC response for SendContainer request, notifies callback on completion/error.
GrpcContainerUploader.WrappedRequestStreamObserver<T>	this class wrap the request stream observer and handle error reported by ratis to response handler.
GrpcReplicationClient	Client to read container data from gRPC.
GrpcReplicationClient.StreamDownloader	gRPC stream observer to CompletableFuture adapter.
GrpcReplicationService	Service to make containers available for replication.
MeasuredReplicator	ContainerReplicator wrapper with additional metrics.
OnDemandContainerReplicationSource	A naive implementation of the replication source which creates a tar file on-demand without pre-create the compressed archives.
PushReplicator	Pushes the container to the target datanode.
ReplicationServer	Separated network server for server2server container replication.
ReplicationServer.ReplicationConfig	Replication-related configuration.
ReplicationSupervisor	Single point to schedule the downloading tasks based on priorities.
ReplicationSupervisor.Builder	Builder for ReplicationSupervisor.
ReplicationSupervisorMetrics	Metrics source to report number of replication tasks.
ReplicationTask	The task to download a container from the sources.
SimpleContainerDownloader	Simple ContainerDownloaderImplementation to download the missing container from the first available datanode.