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

Class GrpcContainerUploader

java.lang.Object

org.apache.hadoop.ozone.container.replication.GrpcContainerUploader

All Implemented Interfaces:

ContainerUploader

public class GrpcContainerUploader
extends Object
implements ContainerUploader

Uploads container to target datanode via gRPC.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	GrpcContainerUploader.SendContainerResponseStreamObserver	Observes gRPC response for SendContainer request, notifies callback on completion/error.
static class	GrpcContainerUploader.WrappedRequestStreamObserver<T>	this class wrap the request stream observer and handle error reported by ratis to response handler.

Constructor Summary

Constructors

Constructor	Description
GrpcContainerUploader(org.apache.hadoop.hdds.conf.ConfigurationSource conf, org.apache.hadoop.hdds.security.x509.certificate.client.CertificateClient certClient, ContainerController containerController)

Method Summary

Modifier and Type	Method	Description
protected GrpcReplicationClient	createReplicationClient(org.apache.hadoop.hdds.protocol.DatanodeDetails target, CopyContainerCompression compression)
OutputStream	startUpload(long containerId, org.apache.hadoop.hdds.protocol.DatanodeDetails target, CompletableFuture<Void> callback, CopyContainerCompression compression)

Methods inherited from class java.lang.Object

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

Constructor Details

GrpcContainerUploader

public GrpcContainerUploader(org.apache.hadoop.hdds.conf.ConfigurationSource conf,
 org.apache.hadoop.hdds.security.x509.certificate.client.CertificateClient certClient,
 ContainerController containerController)

Method Details

startUpload

public OutputStream startUpload(long containerId,
 org.apache.hadoop.hdds.protocol.DatanodeDetails target,
 CompletableFuture<Void> callback,
 CopyContainerCompression compression)
                         throws IOException

Specified by:

startUpload in interface ContainerUploader

Throws:

IOException

createReplicationClient

protected GrpcReplicationClient createReplicationClient(org.apache.hadoop.hdds.protocol.DatanodeDetails target,
 CopyContainerCompression compression)
                                                 throws IOException

Throws:

IOException