本文整理了Java中org.apache.hadoop.ipc.RPC.stopProxy
方法的一些代码示例,展示了RPC.stopProxy
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RPC.stopProxy
方法的具体详情如下:
包路径:org.apache.hadoop.ipc.RPC
类名称:RPC
方法名:stopProxy
[英]Stop the proxy. Proxy must either implement Closeable or must have associated RpcInvocationHandler.
[中]停止代理。代理必须实现Closeable,或者必须具有关联的RPC处理程序。
代码示例来源:origin: apache/hive
synchronized void stopUmbilical() {
if (umbilical != null) {
RPC.stopProxy(umbilical);
}
umbilical = null;
}
代码示例来源:origin: org.apache.hadoop/hadoop-common
@Override
public void close() throws IOException {
RPC.stopProxy(server);
}
代码示例来源:origin: org.apache.hadoop/hadoop-common
@Override
public void close() throws IOException {
RPC.stopProxy(proxy);
}
代码示例来源:origin: org.apache.hadoop/hadoop-common
@Override
public void close() {
RPC.stopProxy(rpcProxy);
}
代码示例来源:origin: org.apache.hadoop/hadoop-common
@Override
public void close() throws IOException {
RPC.stopProxy(rpcProxy);
}
代码示例来源:origin: org.apache.hadoop/hadoop-common
@Override
public void close() throws IOException {
RPC.stopProxy(rpcProxy);
}
代码示例来源:origin: org.apache.hadoop/hadoop-common
@Override
public void close() throws IOException {
RPC.stopProxy(rpcProxy);
}
代码示例来源:origin: org.apache.hadoop/hadoop-common
@Override
public void close() {
RPC.stopProxy(rpcProxy);
}
代码示例来源:origin: org.apache.hadoop/hadoop-common
@Override
public void close() throws IOException {
RPC.stopProxy(rpcProxy);
}
代码示例来源:origin: org.apache.hadoop/hadoop-common
@Override
public void close() throws IOException {
RPC.stopProxy(rpcProxy);
}
代码示例来源:origin: org.apache.hadoop/hadoop-common
@Override
public void close() throws IOException {
RPC.stopProxy(rpcProxy);
}
代码示例来源:origin: apache/hive
public void shutdown() {
if (executor != null) {
executor.shutdownNow();
}
if (taskReporter != null) {
taskReporter.shutdown();
}
if (umbilical != null) {
// TODO: Can this be moved out of the main callback path
RPC.stopProxy(umbilical);
}
}
代码示例来源:origin: apache/hbase
try {
if ((args == null || args.length == 0) && "close".equals(method.getName())) {
RPC.stopProxy(cp);
return null;
} else {
代码示例来源:origin: org.apache.hadoop/hadoop-common
/**
* Try to get the HA state of the node at the given address. This
* function is guaranteed to be "quick" -- ie it has a short timeout
* and no retries. Its only purpose is to avoid fencing a node that
* has already restarted.
*/
boolean tryGracefulFence(HAServiceTarget svc) {
HAServiceProtocol proxy = null;
try {
proxy = svc.getProxy(gracefulFenceConf, gracefulFenceTimeout);
proxy.transitionToStandby(createReqInfo());
return true;
} catch (ServiceFailedException sfe) {
LOG.warn("Unable to gracefully make {} standby ({})",
svc, sfe.getMessage());
} catch (IOException ioe) {
LOG.warn("Unable to gracefully make {} standby (unable to connect)",
svc, ioe);
} finally {
if (proxy != null) {
RPC.stopProxy(proxy);
}
}
return false;
}
代码示例来源:origin: org.apache.hadoop/hadoop-common
LOG.warn("Transport-level exception trying to monitor health of {}",
targetToMonitor, t);
RPC.stopProxy(proxy);
proxy = null;
enterState(State.SERVICE_NOT_RESPONDING);
代码示例来源:origin: org.apache.hadoop/hadoop-hdfs
@Override
public void close() {
if (aliasMaps != null) {
for (InMemoryAliasMapProtocol aliasMap : aliasMaps) {
RPC.stopProxy(aliasMap);
}
}
}
代码示例来源:origin: org.apache.hadoop/hadoop-hdfs
@Override
public void abort() throws IOException {
RPC.stopProxy(backupNode);
doubleBuf = null;
}
代码示例来源:origin: org.apache.hadoop/hadoop-hdfs
@Override
public void close() {
RPC.stopProxy(rpcProxy);
}
代码示例来源:origin: org.apache.hadoop/hadoop-hdfs
@Override
public void close() throws IOException {
RPC.stopProxy(rpcProxy);
}
代码示例来源:origin: org.apache.hadoop/hadoop-hdfs
@Override
public void close() throws IOException {
LOG.info("Stopping rpcProxy in" +
"InMemoryAliasMapProtocolClientSideTranslatorPB");
if (rpcProxy != null) {
RPC.stopProxy(rpcProxy);
}
}
}
内容来源于网络,如有侵权,请联系作者删除!