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

ApplicationClientProtocol.signalToContainer介绍

[英]The interface used by clients to request the ResourceManager to signal a container. For example, the client can send command OUTPUT_THREAD_DUMP to dump threads of the container.

The client, via SignalContainerRequest provides the id of the container and the signal command.

In secure mode,the ResourceManager verifies access to the application before signaling the container. The user needs to have MODIFY_APP permission.

Currently, the ResourceManager returns an empty response on success and throws an exception on rejecting the request.
[中]客户端用于请求ResourceManager向容器发送信号的接口。例如，客户端可以向容器的转储线程发送命令OUTPUT\u THREAD\u DUMP。
客户端通过SignalContainerRequest提供容器id和信号命令。
在安全模式下，ResourceManager在向容器发送信号之前验证对应用程序的访问。用户需要具有MODIFY_APP权限。
当前，ResourceManager在成功时返回空响应，在拒绝请求时抛出异常。

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-router

@Override
public SignalContainerResponse signalToContainer(
  SignalContainerRequest request) throws YarnException, IOException {
 return clientRMProxy.signalToContainer(request);
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-client

@Override
public void signalToContainer(ContainerId containerId,
  SignalContainerCommand command)
    throws YarnException, IOException {
 LOG.info("Signalling container " + containerId + " with command " + command);
 SignalContainerRequest request =
   SignalContainerRequest.newInstance(containerId, command);
 rmClient.signalToContainer(request);
}

代码示例来源：origin: io.hops/hadoop-yarn-client

@Override
 public void signalToContainer(ContainerId containerId,
   SignalContainerCommand command)
     throws YarnException, IOException {
  LOG.info("Signalling container " + containerId + " with command " + command);
  SignalContainerRequest request =
    SignalContainerRequest.newInstance(containerId, command);
  rmClient.signalToContainer(request);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-common

@Override
public SignalContainerResponseProto signalToContainer(
  RpcController controller,
  YarnServiceProtos.SignalContainerRequestProto proto) throws ServiceException {
 SignalContainerRequestPBImpl request = new SignalContainerRequestPBImpl(proto);
 try {
  SignalContainerResponse response = real.signalToContainer(request);
  return ((SignalContainerResponsePBImpl)response).getProto();
 } catch (YarnException e) {
  throw new ServiceException(e);
 } catch (IOException e) {
  throw new ServiceException(e);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

public void signalToContainer(ContainerId containerId,
  SignalContainerCommand command) throws Exception {
 ApplicationClientProtocol client = getClientRMService();
 SignalContainerRequest req =
   SignalContainerRequest.newInstance(containerId, command);
 client.signalToContainer(req);
 drainEventsImplicitly();
}