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

Class GrpcReplicationClient.StreamDownloader

java.lang.Object

org.apache.hadoop.ozone.container.replication.GrpcReplicationClient.StreamDownloader

All Implemented Interfaces:

org.apache.ratis.thirdparty.io.grpc.stub.StreamObserver<org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.CopyContainerResponseProto>

Enclosing class:

GrpcReplicationClient

public static class GrpcReplicationClient.StreamDownloader
extends Object
implements org.apache.ratis.thirdparty.io.grpc.stub.StreamObserver<org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.CopyContainerResponseProto>

gRPC stream observer to CompletableFuture adapter.

Constructor Summary

Constructors

Constructor	Description
StreamDownloader(long containerId, CompletableFuture<Path> response, Path outputPath)

Method Summary

Modifier and Type	Method	Description
void	onCompleted()
void	onError(Throwable throwable)
void	onNext(org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.CopyContainerResponseProto chunk)

Methods inherited from class java.lang.Object

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

Constructor Details

StreamDownloader

public StreamDownloader(long containerId,
 CompletableFuture<Path> response,
 Path outputPath)

Method Details

onNext

public void onNext(org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.CopyContainerResponseProto chunk)

Specified by:

onNext in interface org.apache.ratis.thirdparty.io.grpc.stub.StreamObserver<org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.CopyContainerResponseProto>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface org.apache.ratis.thirdparty.io.grpc.stub.StreamObserver<org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.CopyContainerResponseProto>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface org.apache.ratis.thirdparty.io.grpc.stub.StreamObserver<org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.CopyContainerResponseProto>