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

YarnClientImpl介绍

暂无

代码示例

代码示例来源：origin: apache/flink

@Override
  public ApplicationReport getApplicationReport(ApplicationId appId) throws YarnException, IOException {
    final ApplicationReport applicationReport = applicationReports.get(appId);
    if (applicationReport != null) {
      return applicationReport;
    } else {
      return super.getApplicationReport(appId);
    }
  }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-client

if (isSecurityEnabled() && timelineServiceEnabled) {
 addTimelineDelegationToken(appContext.getAMContainerSpec());
while (true) {
 try {
  ApplicationReport appReport = getApplicationReport(applicationId);
  YarnApplicationState state = appReport.getYarnApplicationState();
  if (!waitingStates.contains(state)) {
  if (enforceAsyncAPITimeout() &&
    elapsedMillis >= asyncApiPollTimeoutMillis) {
   throw new YarnException("Timed out while waiting for application " +

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

@Override
public List<QueueInfo> getChildQueueInfos(String parent)
  throws YarnException, IOException {
 List<QueueInfo> queues = new ArrayList<QueueInfo>();
 QueueInfo parentQueue =
   rmClient.getQueueInfo(getQueueInfoRequest(parent, false, true, false))
    .getQueueInfo();
 getChildQueues(parentQueue, queues, true);
 return queues;
}

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

@Override
public List<ApplicationReport> getApplications(Set<String> applicationTypes)
  throws YarnException,
  IOException {
 return getApplications(applicationTypes, null);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-client

YarnConfiguration.DEFAULT_TIMELINE_SERVICE_ENABLED)) {
timelineServiceEnabled = true;
timelineClient = createTimelineClient();
timelineClient.init(conf);
timelineDTRenewer = getTimelineDelegationTokenRenewer(conf);
timelineService = TimelineUtils.buildTimelineTokenService(conf);

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

synchronized (this) {
 if (timelineClient == null) {
  TimelineClient tlClient = createTimelineClient();
  tlClient.init(getConfig());
  tlClient.start();

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

@Override
public YarnClientApplication createApplication()
  throws YarnException, IOException {
 ApplicationSubmissionContext context = Records.newRecord
   (ApplicationSubmissionContext.class);
 GetNewApplicationResponse newApp = getNewApplication();
 ApplicationId appId = newApp.getApplicationId();
 context.setApplicationId(appId);
 return new YarnClientApplication(newApp, context);
}

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

private void getChildQueues(QueueInfo parent, List<QueueInfo> queues,
  boolean recursive) {
 List<QueueInfo> childQueues = parent.getChildQueues();
 for (QueueInfo child : childQueues) {
  queues.add(child);
  if (recursive) {
   getChildQueues(child, queues, recursive);
  }
 }
}

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

@Override
public QueueInfo getQueueInfo(String queueName) throws YarnException,
  IOException {
 GetQueueInfoRequest request =
   getQueueInfoRequest(queueName, true, false, false);
 Records.newRecord(GetQueueInfoRequest.class);
 return rmClient.getQueueInfo(request).getQueueInfo();
}

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

/**
 * Create a new instance of YarnClient.
 */
@Public
public static YarnClient createYarnClient() {
 YarnClient client = new YarnClientImpl();
 return client;
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-client

if (enforceAsyncAPITimeout() &&
  elapsedMillis >= this.asyncApiPollTimeoutMillis) {
 throw new YarnException("Timed out while waiting for application " +

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

@Override
protected void serviceStart() throws Exception {
 try {
  rmClient = ClientRMProxy.createRMProxy(getConfig(),
    ApplicationClientProtocol.class);
  if (historyServiceEnabled) {
   historyClient.start();
  }
 } catch (IOException e) {
  throw new YarnRuntimeException(e);
 }
 // Reinitialize local resource types cache from list of resources pulled from
 // RM.
 if (loadResourceTypesFromServer) {
  ResourceUtils.reinitializeResources(getResourceTypeInfo());
 }
 super.serviceStart();
}

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

@Override
protected void serviceStart() throws Exception {
 try {
  rmClient = ClientRMProxy.createRMProxy(getConfig(),
    ApplicationClientProtocol.class, true);
  if (historyServiceEnabled) {
   historyClient.start();
  }
 } catch (IOException e) {
  throw new YarnRuntimeException(e);
 }
 super.serviceStart();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-client

if (isSecurityEnabled() && timelineServiceEnabled) {
 addTimelineDelegationToken(appContext.getAMContainerSpec());
while (true) {
 try {
  ApplicationReport appReport = getApplicationReport(applicationId);
  YarnApplicationState state = appReport.getYarnApplicationState();
  if (!waitingStates.contains(state)) {
  if (enforceAsyncAPITimeout() &&
    elapsedMillis >= asyncApiPollTimeoutMillis) {
   throw new YarnException("Timed out while waiting for application " +

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-client

@Override
public List<QueueInfo> getRootQueueInfos() throws YarnException,
  IOException {
 List<QueueInfo> queues = new ArrayList<QueueInfo>();
 QueueInfo rootQueue =
   rmClient.getQueueInfo(getQueueInfoRequest(ROOT, false, true, true))
    .getQueueInfo();
 getChildQueues(rootQueue, queues, false);
 return queues;
}

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

@Override
public List<ApplicationReport> getApplications() throws YarnException,
  IOException {
 return getApplications(null, null);
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-client

YarnConfiguration.DEFAULT_TIMELINE_SERVICE_ENABLED)) {
timelineServiceEnabled = true;
timelineClient = createTimelineClient();
timelineClient.init(conf);
timelineDTRenewer = getTimelineDelegationTokenRenewer(conf);
timelineService = TimelineUtils.buildTimelineTokenService(conf);

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

synchronized (this) {
 if (timelineClient == null) {
  timelineClient = createTimelineClient();
  timelineClient.init(getConfig());
  timelineClient.start();

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-client

@Override
public YarnClientApplication createApplication()
  throws YarnException, IOException {
 ApplicationSubmissionContext context = Records.newRecord
   (ApplicationSubmissionContext.class);
 GetNewApplicationResponse newApp = getNewApplication();
 ApplicationId appId = newApp.getApplicationId();
 context.setApplicationId(appId);
 return new YarnClientApplication(newApp, context);
}

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

private void getChildQueues(QueueInfo parent, List<QueueInfo> queues,
  boolean recursive) {
 List<QueueInfo> childQueues = parent.getChildQueues();
 for (QueueInfo child : childQueues) {
  queues.add(child);
  if (recursive) {
   getChildQueues(child, queues, recursive);
  }
 }
}