static Writable call(Client client, Writable param,
InetSocketAddress address) throws IOException {
final ConnectionId remoteId = ConnectionId.getConnectionId(address, null,
null, 0, null, conf);
return client.call(RpcKind.RPC_BUILTIN, param, remoteId,
RPC.RPC_SERVICE_CLASS_DEFAULT, null);
}
TestIPCServerResponder.java 文件源码
java
阅读 20
收藏 0
点赞 0
评论 0
项目:hadoop-oss
作者:
评论列表
文章目录