public static final class ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.Stub extends ClientDatanodeProtocolProtos.ClientDatanodeProtocolService implements ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.Interface
ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.BlockingInterface, ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.Interface, ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.Stub
Modifier and Type | Method and Description |
---|---|
void |
deleteBlockPool(com.google.protobuf.RpcController controller,
ClientDatanodeProtocolProtos.DeleteBlockPoolRequestProto request,
com.google.protobuf.RpcCallback<ClientDatanodeProtocolProtos.DeleteBlockPoolResponseProto> done)
rpc deleteBlockPool(.hadoop.hdfs.DeleteBlockPoolRequestProto) returns (.hadoop.hdfs.DeleteBlockPoolResponseProto); |
void |
getBlockLocalPathInfo(com.google.protobuf.RpcController controller,
ClientDatanodeProtocolProtos.GetBlockLocalPathInfoRequestProto request,
com.google.protobuf.RpcCallback<ClientDatanodeProtocolProtos.GetBlockLocalPathInfoResponseProto> done)
rpc getBlockLocalPathInfo(.hadoop.hdfs.GetBlockLocalPathInfoRequestProto) returns (.hadoop.hdfs.GetBlockLocalPathInfoResponseProto); |
com.google.protobuf.RpcChannel |
getChannel() |
void |
getHdfsBlockLocations(com.google.protobuf.RpcController controller,
ClientDatanodeProtocolProtos.GetHdfsBlockLocationsRequestProto request,
com.google.protobuf.RpcCallback<ClientDatanodeProtocolProtos.GetHdfsBlockLocationsResponseProto> done)
rpc getHdfsBlockLocations(.hadoop.hdfs.GetHdfsBlockLocationsRequestProto) returns (.hadoop.hdfs.GetHdfsBlockLocationsResponseProto); |
void |
getReplicaVisibleLength(com.google.protobuf.RpcController controller,
ClientDatanodeProtocolProtos.GetReplicaVisibleLengthRequestProto request,
com.google.protobuf.RpcCallback<ClientDatanodeProtocolProtos.GetReplicaVisibleLengthResponseProto> done)
rpc getReplicaVisibleLength(.hadoop.hdfs.GetReplicaVisibleLengthRequestProto) returns (.hadoop.hdfs.GetReplicaVisibleLengthResponseProto); |
void |
refreshNamenodes(com.google.protobuf.RpcController controller,
ClientDatanodeProtocolProtos.RefreshNamenodesRequestProto request,
com.google.protobuf.RpcCallback<ClientDatanodeProtocolProtos.RefreshNamenodesResponseProto> done)
rpc refreshNamenodes(.hadoop.hdfs.RefreshNamenodesRequestProto) returns (.hadoop.hdfs.RefreshNamenodesResponseProto); |
callMethod, getDescriptor, getDescriptorForType, getRequestPrototype, getResponsePrototype, newBlockingStub, newReflectiveBlockingService, newReflectiveService, newStub
public com.google.protobuf.RpcChannel getChannel()
public void getReplicaVisibleLength(com.google.protobuf.RpcController controller, ClientDatanodeProtocolProtos.GetReplicaVisibleLengthRequestProto request, com.google.protobuf.RpcCallback<ClientDatanodeProtocolProtos.GetReplicaVisibleLengthResponseProto> done)
ClientDatanodeProtocolProtos.ClientDatanodeProtocolService
rpc getReplicaVisibleLength(.hadoop.hdfs.GetReplicaVisibleLengthRequestProto) returns (.hadoop.hdfs.GetReplicaVisibleLengthResponseProto);
Returns the visible length of the replica
getReplicaVisibleLength
in interface ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.Interface
getReplicaVisibleLength
in class ClientDatanodeProtocolProtos.ClientDatanodeProtocolService
public void refreshNamenodes(com.google.protobuf.RpcController controller, ClientDatanodeProtocolProtos.RefreshNamenodesRequestProto request, com.google.protobuf.RpcCallback<ClientDatanodeProtocolProtos.RefreshNamenodesResponseProto> done)
ClientDatanodeProtocolProtos.ClientDatanodeProtocolService
rpc refreshNamenodes(.hadoop.hdfs.RefreshNamenodesRequestProto) returns (.hadoop.hdfs.RefreshNamenodesResponseProto);
Refresh the list of federated namenodes from updated configuration. Adds new namenodes and stops the deleted namenodes.
refreshNamenodes
in interface ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.Interface
refreshNamenodes
in class ClientDatanodeProtocolProtos.ClientDatanodeProtocolService
public void deleteBlockPool(com.google.protobuf.RpcController controller, ClientDatanodeProtocolProtos.DeleteBlockPoolRequestProto request, com.google.protobuf.RpcCallback<ClientDatanodeProtocolProtos.DeleteBlockPoolResponseProto> done)
ClientDatanodeProtocolProtos.ClientDatanodeProtocolService
rpc deleteBlockPool(.hadoop.hdfs.DeleteBlockPoolRequestProto) returns (.hadoop.hdfs.DeleteBlockPoolResponseProto);
Delete the block pool from the datanode.
deleteBlockPool
in interface ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.Interface
deleteBlockPool
in class ClientDatanodeProtocolProtos.ClientDatanodeProtocolService
public void getBlockLocalPathInfo(com.google.protobuf.RpcController controller, ClientDatanodeProtocolProtos.GetBlockLocalPathInfoRequestProto request, com.google.protobuf.RpcCallback<ClientDatanodeProtocolProtos.GetBlockLocalPathInfoResponseProto> done)
ClientDatanodeProtocolProtos.ClientDatanodeProtocolService
rpc getBlockLocalPathInfo(.hadoop.hdfs.GetBlockLocalPathInfoRequestProto) returns (.hadoop.hdfs.GetBlockLocalPathInfoResponseProto);
Retrieves the path names of the block file and metadata file stored on the local file system.
getBlockLocalPathInfo
in interface ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.Interface
getBlockLocalPathInfo
in class ClientDatanodeProtocolProtos.ClientDatanodeProtocolService
public void getHdfsBlockLocations(com.google.protobuf.RpcController controller, ClientDatanodeProtocolProtos.GetHdfsBlockLocationsRequestProto request, com.google.protobuf.RpcCallback<ClientDatanodeProtocolProtos.GetHdfsBlockLocationsResponseProto> done)
ClientDatanodeProtocolProtos.ClientDatanodeProtocolService
rpc getHdfsBlockLocations(.hadoop.hdfs.GetHdfsBlockLocationsRequestProto) returns (.hadoop.hdfs.GetHdfsBlockLocationsResponseProto);
Retrieve additional HDFS-specific metadata about a set of blocks stored on the local file system.
getHdfsBlockLocations
in interface ClientDatanodeProtocolProtos.ClientDatanodeProtocolService.Interface
getHdfsBlockLocations
in class ClientDatanodeProtocolProtos.ClientDatanodeProtocolService
Copyright © 2013 Apache Software Foundation. All rights reserved.