本文整理汇总了Java中org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos类的典型用法代码示例。如果您正苦于以下问题:Java ClientNamenodeProtocolProtos类的具体用法?Java ClientNamenodeProtocolProtos怎么用?Java ClientNamenodeProtocolProtos使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ClientNamenodeProtocolProtos类属于org.apache.hadoop.hdfs.protocol.proto包,在下文中一共展示了ClientNamenodeProtocolProtos类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getMissingBlockLocations
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public ClientNamenodeProtocolProtos.GetMissingBlockLocationsResponseProto getMissingBlockLocations(
RpcController controller,
ClientNamenodeProtocolProtos.GetMissingBlockLocationsRequestProto req)
throws ServiceException {
try {
LocatedBlocks b = server.getMissingBlockLocations(req.getFilePath());
ClientNamenodeProtocolProtos.GetMissingBlockLocationsResponseProto.Builder
builder =
ClientNamenodeProtocolProtos.GetMissingBlockLocationsResponseProto
.newBuilder();
if (b != null) {
builder.setLocations(PBHelper.convert(b)).build();
}
return builder.build();
} catch (IOException e) {
throw new ServiceException(e);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:20,代码来源:ClientNamenodeProtocolServerSideTranslatorPB.java
示例2: getBlockChecksum
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public ClientNamenodeProtocolProtos.GetBlockChecksumResponseProto getBlockChecksum(
RpcController controller,
ClientNamenodeProtocolProtos.GetBlockChecksumRequestProto req)
throws ServiceException {
try {
long checksum =
server.getBlockChecksum(req.getSrc(), req.getBlockIndex());
ClientNamenodeProtocolProtos.GetBlockChecksumResponseProto.Builder
builder = ClientNamenodeProtocolProtos.GetBlockChecksumResponseProto
.newBuilder().setChecksum(checksum);
return builder.build();
} catch (IOException e) {
throw new ServiceException(e);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:17,代码来源:ClientNamenodeProtocolServerSideTranslatorPB.java
示例3: getEncodingStatus
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public ClientNamenodeProtocolProtos.GetEncodingStatusResponseProto getEncodingStatus(
RpcController controller,
ClientNamenodeProtocolProtos.GetEncodingStatusRequestProto request)
throws ServiceException {
try {
EncodingStatus status = server.getEncodingStatus(request.getPath());
ClientNamenodeProtocolProtos.GetEncodingStatusResponseProto.Builder
builder = ClientNamenodeProtocolProtos.GetEncodingStatusResponseProto
.newBuilder();
builder.setEncodingStatus(PBHelper.convert(status));
return builder.build();
} catch (IOException e) {
throw new ServiceException(e);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:17,代码来源:ClientNamenodeProtocolServerSideTranslatorPB.java
示例4: getRepairedBlockLocations
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public ClientNamenodeProtocolProtos.GetRepairedBlockLocationsResponseProto getRepairedBlockLocations(
RpcController controller,
ClientNamenodeProtocolProtos.GetRepairedBlockLocationsRequsestProto request)
throws ServiceException {
try {
LocatedBlock b = server.getRepairedBlockLocations(request.getSourcePath(),
request.getParityPath(), PBHelper.convert(request.getBlock()),
request.getIsParity());
ClientNamenodeProtocolProtos.GetRepairedBlockLocationsResponseProto.Builder
builder =
ClientNamenodeProtocolProtos.GetRepairedBlockLocationsResponseProto
.newBuilder();
if (b != null) {
builder.setLocatedBlocks(PBHelper.convert(b)).build();
}
return builder.build();
} catch (IOException e) {
throw new ServiceException(e);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:22,代码来源:ClientNamenodeProtocolServerSideTranslatorPB.java
示例5: getRepairedBlockLocations
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public LocatedBlock getRepairedBlockLocations(String sourcePath,
String parityPath, LocatedBlock block, boolean isParity)
throws IOException {
ClientNamenodeProtocolProtos.GetRepairedBlockLocationsRequsestProto
request =
ClientNamenodeProtocolProtos.GetRepairedBlockLocationsRequsestProto
.newBuilder().setSourcePath(sourcePath).setParityPath(parityPath)
.setIsParity(isParity).setBlock(PBHelper.convert(block)).build();
try {
return PBHelper.convert(
rpcProxy.getRepairedBlockLocations(null, request).getLocatedBlocks());
} catch (ServiceException e) {
throw ProtobufHelper.getRemoteException(e);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:17,代码来源:ClientNamenodeProtocolTranslatorPB.java
示例6: flushCache
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public void flushCache(String userName, String groupName) throws IOException {
try {
ClientNamenodeProtocolProtos.FlushUsersCacheRequestProto.Builder req =
ClientNamenodeProtocolProtos.FlushUsersCacheRequestProto.newBuilder();
if(userName != null) {
req.setUserName(userName);
}
if(groupName != null) {
req.setGroupName(groupName);
}
rpcProxy.flushCache(null, req.build());
} catch (ServiceException ex) {
throw ProtobufHelper.getRemoteException(ex);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:17,代码来源:ClientNamenodeProtocolTranslatorPB.java
示例7: convert
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
public static SafeModeAction convert(
ClientNamenodeProtocolProtos.SafeModeActionProto a) {
switch (a) {
case SAFEMODE_LEAVE:
return SafeModeAction.SAFEMODE_LEAVE;
case SAFEMODE_ENTER:
return SafeModeAction.SAFEMODE_ENTER;
case SAFEMODE_GET:
return SafeModeAction.SAFEMODE_GET;
default:
throw new IllegalArgumentException("Unexpected SafeModeAction :" + a);
}
}
开发者ID:naver,项目名称:hadoop,代码行数:14,代码来源:PBHelper.java
示例8: start
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
public void start() throws IOException {
int rpcHandlerCount = conf.getInt(ProxyConfig.PROXY_HANDLER_COUNT, ProxyConfig.PROXY_HANDLER_COUNT_DEFAULT);
RPC.setProtocolEngine(conf, ClientNamenodeProtocolPB.class,
ProtobufRpcEngine.class);
RPC.setProtocolEngine(conf, NamenodeProtocolPB.class,
ProtobufRpcEngine.class);
this.protocol = (ClientProtocol) Proxy.newProxyInstance(
this.getClass().getClassLoader(),
new Class[]{ClientProtocol.class},
this.invocationHandler);
ClientNamenodeProtocolPB proxy = new ClientNamenodeProtocolServerSideTranslatorPB(this.protocol);
BlockingService clientNNPbService = ClientNamenodeProtocolProtos.ClientNamenodeProtocol.
newReflectiveBlockingService(proxy);
int port = conf.getInt(ProxyConfig.RPC_PORT, ProxyConfig.RPC_PORT_DEFAULT);
this.rpcServer = new RPC.Builder(conf)
.setProtocol(org.apache.hadoop.hdfs.protocolPB.ClientNamenodeProtocolPB.class)
.setInstance(clientNNPbService).setBindAddress("0.0.0.0")
.setPort(port).setNumHandlers(rpcHandlerCount)
.setVerbose(false).build();
this.rpcServer.start();
InetSocketAddress listenAddr = rpcServer.getListenerAddress();
rpcAddress = new InetSocketAddress("0.0.0.0", listenAddr.getPort());
}
开发者ID:bytedance,项目名称:nnproxy,代码行数:29,代码来源:ProxyServer.java
示例9: convert
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
public static SafeModeAction convert(
ClientNamenodeProtocolProtos.SafeModeActionProto a) {
switch (a) {
case SAFEMODE_LEAVE:
return SafeModeAction.SAFEMODE_LEAVE;
case SAFEMODE_ENTER:
return SafeModeAction.SAFEMODE_ENTER;
case SAFEMODE_GET:
return SafeModeAction.SAFEMODE_GET;
default:
throw new IllegalArgumentException("Unexpected SafeModeAction :" + a);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:14,代码来源:PBHelper.java
示例10: addBlockChecksum
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public ClientNamenodeProtocolProtos.AddBlockChecksumResponseProto addBlockChecksum(
RpcController controller,
ClientNamenodeProtocolProtos.AddBlockChecksumRequestProto req)
throws ServiceException {
try {
server.addBlockChecksum(req.getSrc(), req.getBlockIndex(),
req.getChecksum());
} catch (IOException e) {
throw new ServiceException(e);
}
return VOID_ADDBLOCKCHECKSUM_RESPONSE;
}
开发者ID:hopshadoop,项目名称:hops,代码行数:14,代码来源:ClientNamenodeProtocolServerSideTranslatorPB.java
示例11: setMetaEnabled
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public ClientNamenodeProtocolProtos.SetMetaEnabledResponseProto setMetaEnabled(
RpcController controller,
ClientNamenodeProtocolProtos.SetMetaEnabledRequestProto req)
throws ServiceException {
try {
server.setMetaEnabled(req.getSrc(), req.getMetaEnabled());
} catch (IOException e) {
throw new ServiceException(e);
}
return VOID_SET_META_ENABLED_RESPONSE;
}
开发者ID:hopshadoop,项目名称:hops,代码行数:13,代码来源:ClientNamenodeProtocolServerSideTranslatorPB.java
示例12: ping
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public ClientNamenodeProtocolProtos.PingResponseProto ping(
RpcController controller,
ClientNamenodeProtocolProtos.PingRequestProto request)
throws ServiceException {
try {
server.ping();
PingResponseProto.Builder builder = PingResponseProto.newBuilder();
return builder.build();
} catch (IOException ex) {
throw new ServiceException(ex);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:14,代码来源:ClientNamenodeProtocolServerSideTranslatorPB.java
示例13: encodeFile
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public ClientNamenodeProtocolProtos.EncodeFileResponseProto encodeFile(
RpcController controller,
ClientNamenodeProtocolProtos.EncodeFileRequestProto request)
throws ServiceException {
try {
server
.encodeFile(request.getPath(), PBHelper.convert(request.getPolicy()));
ClientNamenodeProtocolProtos.EncodeFileResponseProto.Builder builder =
ClientNamenodeProtocolProtos.EncodeFileResponseProto.newBuilder();
return builder.build();
} catch (IOException e) {
throw new ServiceException(e);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:16,代码来源:ClientNamenodeProtocolServerSideTranslatorPB.java
示例14: revokeEncoding
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public ClientNamenodeProtocolProtos.RevokeEncodingResponseProto revokeEncoding(
RpcController controller,
ClientNamenodeProtocolProtos.RevokeEncodingRequestProto request)
throws ServiceException {
try {
server
.revokeEncoding(request.getPath(), (short) request.getReplication());
ClientNamenodeProtocolProtos.RevokeEncodingResponseProto.Builder builder =
ClientNamenodeProtocolProtos.RevokeEncodingResponseProto.newBuilder();
return builder.build();
} catch (IOException e) {
throw new ServiceException(e);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:16,代码来源:ClientNamenodeProtocolServerSideTranslatorPB.java
示例15: getActiveNamenodesForClient
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public ClientNamenodeProtocolProtos.ActiveNamenodeListResponseProto getActiveNamenodesForClient(
RpcController controller,
ClientNamenodeProtocolProtos.ActiveNamenodeListRequestProto request)
throws ServiceException {
try {
SortedActiveNodeList anl = server.getActiveNamenodesForClient();
ClientNamenodeProtocolProtos.ActiveNamenodeListResponseProto response =
convertANListToResponseProto(anl);
return response;
} catch (IOException e) {
throw new ServiceException(e);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:15,代码来源:ClientNamenodeProtocolServerSideTranslatorPB.java
示例16: convertANListToResponseProto
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
private ClientNamenodeProtocolProtos.ActiveNamenodeListResponseProto convertANListToResponseProto(
SortedActiveNodeList anlWrapper) {
List<ActiveNode> anl = anlWrapper.getActiveNodes();
ClientNamenodeProtocolProtos.ActiveNamenodeListResponseProto.Builder
anlrpb = ClientNamenodeProtocolProtos.ActiveNamenodeListResponseProto
.newBuilder();
for (ActiveNode anAnl : anl) {
ActiveNodeProtos.ActiveNodeProto anp =
convertANToResponseProto(anAnl);
anlrpb.addNamenodes(anp);
}
return anlrpb.build();
}
开发者ID:hopshadoop,项目名称:hops,代码行数:14,代码来源:ClientNamenodeProtocolServerSideTranslatorPB.java
示例17: changeConf
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public ClientNamenodeProtocolProtos.ChangeConfResponseProto changeConf(
RpcController controller,
ClientNamenodeProtocolProtos.ChangeConfProto request)
throws ServiceException {
try {
server.changeConf(request.getPropsList(), request.getNewValsList());
return VOID_CHANGECONF_RESPONSE;
} catch (IOException ex) {
throw new ServiceException(ex);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:13,代码来源:ClientNamenodeProtocolServerSideTranslatorPB.java
示例18: flushCache
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public ClientNamenodeProtocolProtos.FlushUsersCacheResponseProto flushCache(
RpcController controller,
ClientNamenodeProtocolProtos.FlushUsersCacheRequestProto request)
throws ServiceException {
try {
server.flushCache(request.getUserName(), request.getGroupName());
return VOID_FLUSH_CACHE;
} catch (IOException ex) {
throw new ServiceException(ex);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:13,代码来源:ClientNamenodeProtocolServerSideTranslatorPB.java
示例19: getMissingBlockLocations
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public LocatedBlocks getMissingBlockLocations(String filePath)
throws AccessControlException, FileNotFoundException,
UnresolvedLinkException, IOException {
ClientNamenodeProtocolProtos.GetMissingBlockLocationsRequestProto req =
ClientNamenodeProtocolProtos.GetMissingBlockLocationsRequestProto
.newBuilder().setFilePath(filePath).build();
try {
ClientNamenodeProtocolProtos.GetMissingBlockLocationsResponseProto resp =
rpcProxy.getMissingBlockLocations(null, req);
return resp.hasLocations() ? PBHelper.convert(resp.getLocations()) : null;
} catch (ServiceException e) {
throw ProtobufHelper.getRemoteException(e);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:16,代码来源:ClientNamenodeProtocolTranslatorPB.java
示例20: addBlockChecksum
import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos; //导入依赖的package包/类
@Override
public void addBlockChecksum(String src, int blockIndex, long checksum)
throws IOException {
ClientNamenodeProtocolProtos.AddBlockChecksumRequestProto req =
ClientNamenodeProtocolProtos.AddBlockChecksumRequestProto.newBuilder()
.setSrc(src).setBlockIndex(blockIndex).setChecksum(checksum)
.build();
try {
rpcProxy.addBlockChecksum(null, req);
} catch (ServiceException e) {
throw ProtobufHelper.getRemoteException(e);
}
}
开发者ID:hopshadoop,项目名称:hops,代码行数:14,代码来源:ClientNamenodeProtocolTranslatorPB.java
注:本文中的org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论