org.apache.hadoop.ipc.RPC.stopProxy()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(3.6k)|赞(0)|评价(0)|浏览(164)

本文整理了Java中org.apache.hadoop.ipc.RPC.stopProxy方法的一些代码示例,展示了RPC.stopProxy的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RPC.stopProxy方法的具体详情如下:
包路径:org.apache.hadoop.ipc.RPC
类名称:RPC
方法名:stopProxy

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);
  }
 }
}

相关文章