Package org.apache.hadoop.ozone.container.checksum

Class DNContainerOperationClient

java.lang.Object

org.apache.hadoop.ozone.container.checksum.DNContainerOperationClient

All Implemented Interfaces:

AutoCloseable

public class DNContainerOperationClient
extends Object
implements AutoCloseable

This class wraps necessary container-level rpc calls for container reconciliation. - GetContainerMerkleTree

Constructor Summary

Constructors

Constructor	Description
DNContainerOperationClient(org.apache.hadoop.hdds.conf.ConfigurationSource conf, org.apache.hadoop.hdds.security.x509.certificate.client.CertificateClient certificateClient, org.apache.hadoop.hdds.security.symmetric.SecretKeySignerClient secretKeyClient)

Method Summary

Modifier and Type	Method	Description
void	close()
static org.apache.hadoop.hdds.scm.pipeline.Pipeline	createSingleNodePipeline(org.apache.hadoop.hdds.protocol.DatanodeDetails dn)
org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerChecksumInfo	getContainerChecksumInfo(long containerId, org.apache.hadoop.hdds.protocol.DatanodeDetails dn)	Reads ContainerProtos.ContainerChecksumInfo for a specified container for the specified datanode.
TokenHelper	getTokenHelper()
org.apache.hadoop.hdds.scm.XceiverClientManager	getXceiverClientManager()

Methods inherited from class java.lang.Object

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

Constructor Details

DNContainerOperationClient

public DNContainerOperationClient(org.apache.hadoop.hdds.conf.ConfigurationSource conf,
 org.apache.hadoop.hdds.security.x509.certificate.client.CertificateClient certificateClient,
 org.apache.hadoop.hdds.security.symmetric.SecretKeySignerClient secretKeyClient)
                           throws IOException

Throws:

IOException

Method Details

getXceiverClientManager

public org.apache.hadoop.hdds.scm.XceiverClientManager getXceiverClientManager()

getTokenHelper

public TokenHelper getTokenHelper()

getContainerChecksumInfo

public org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerChecksumInfo getContainerChecksumInfo(long containerId,
 org.apache.hadoop.hdds.protocol.DatanodeDetails dn)
                                                                                                              throws IOException

Reads ContainerProtos.ContainerChecksumInfo for a specified container for the specified datanode.

Throws:

IOException - For errors communicating with the datanode.

org.apache.hadoop.hdds.scm.container.common.helpers.StorageContainerException - For errors obtaining the checksum info, including the file being missing or empty on the datanode, or the datanode not having a replica of the container.

org.apache.ratis.thirdparty.com.google.protobuf.InvalidProtocolBufferException - If the file received from the datanode cannot be deserialized.

createSingleNodePipeline

public static org.apache.hadoop.hdds.scm.pipeline.Pipeline createSingleNodePipeline(org.apache.hadoop.hdds.protocol.DatanodeDetails dn)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException