org.apache.hadoop.hdfs.protocolPB

Class ClientDatanodeProtocolServerSideTranslatorPB

java.lang.Object

org.apache.hadoop.hdfs.protocolPB.ClientDatanodeProtocolServerSideTranslatorPB

All Implemented Interfaces:

ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.BlockingInterface, ClientDatanodeProtocolPB

@InterfaceAudience.Private
public class ClientDatanodeProtocolServerSideTranslatorPB
extends Object
implements ClientDatanodeProtocolPB

Implementation for protobuf service that forwards requests received on ClientDatanodeProtocolPB to the ClientDatanodeProtocol server implementation.

Constructor Summary

Constructors

Constructor and Description
ClientDatanodeProtocolServerSideTranslatorPB(ClientDatanodeProtocol impl)

Method Summary

Methods

Modifier and Type	Method and Description
ClientDatanodeProtocolProtos.DeleteBlockPoolResponseProto	deleteBlockPool(com.google.protobuf.RpcController unused, ClientDatanodeProtocolProtos.DeleteBlockPoolRequestProto request)
ClientDatanodeProtocolProtos.GetBlockLocalPathInfoResponseProto	getBlockLocalPathInfo(com.google.protobuf.RpcController unused, ClientDatanodeProtocolProtos.GetBlockLocalPathInfoRequestProto request)
ClientDatanodeProtocolProtos.GetHdfsBlockLocationsResponseProto	getHdfsBlockLocations(com.google.protobuf.RpcController controller, ClientDatanodeProtocolProtos.GetHdfsBlockLocationsRequestProto request)
ClientDatanodeProtocolProtos.GetReplicaVisibleLengthResponseProto	getReplicaVisibleLength(com.google.protobuf.RpcController unused, ClientDatanodeProtocolProtos.GetReplicaVisibleLengthRequestProto request)
ClientDatanodeProtocolProtos.RefreshNamenodesResponseProto	refreshNamenodes(com.google.protobuf.RpcController unused, ClientDatanodeProtocolProtos.RefreshNamenodesRequestProto request)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientDatanodeProtocolServerSideTranslatorPB

public ClientDatanodeProtocolServerSideTranslatorPB(ClientDatanodeProtocol impl)

Method Detail

getReplicaVisibleLength

public ClientDatanodeProtocolProtos.GetReplicaVisibleLengthResponseProto getReplicaVisibleLength(com.google.protobuf.RpcController unused,
                                                                                        ClientDatanodeProtocolProtos.GetReplicaVisibleLengthRequestProto request)
                                                                                          throws com.google.protobuf.ServiceException

Specified by:

getReplicaVisibleLength in interface ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

refreshNamenodes

public ClientDatanodeProtocolProtos.RefreshNamenodesResponseProto refreshNamenodes(com.google.protobuf.RpcController unused,
                                                                          ClientDatanodeProtocolProtos.RefreshNamenodesRequestProto request)
                                                                            throws com.google.protobuf.ServiceException

Specified by:

refreshNamenodes in interface ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

deleteBlockPool

public ClientDatanodeProtocolProtos.DeleteBlockPoolResponseProto deleteBlockPool(com.google.protobuf.RpcController unused,
                                                                        ClientDatanodeProtocolProtos.DeleteBlockPoolRequestProto request)
                                                                          throws com.google.protobuf.ServiceException

Specified by:

deleteBlockPool in interface ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getBlockLocalPathInfo

public ClientDatanodeProtocolProtos.GetBlockLocalPathInfoResponseProto getBlockLocalPathInfo(com.google.protobuf.RpcController unused,
                                                                                    ClientDatanodeProtocolProtos.GetBlockLocalPathInfoRequestProto request)
                                                                                      throws com.google.protobuf.ServiceException

Specified by:

getBlockLocalPathInfo in interface ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getHdfsBlockLocations

public ClientDatanodeProtocolProtos.GetHdfsBlockLocationsResponseProto getHdfsBlockLocations(com.google.protobuf.RpcController controller,
                                                                                    ClientDatanodeProtocolProtos.GetHdfsBlockLocationsRequestProto request)
                                                                                      throws com.google.protobuf.ServiceException

Specified by:

getHdfsBlockLocations in interface ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.BlockingInterface

Throws:

com.google.protobuf.ServiceException