org.apache.hadoop.yarn.server.webapp.WebServices类的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(11.1k)|赞(0)|评价(0)|浏览(185)

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

WebServices介绍

暂无

代码示例

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

public ApplicationsRequestBuilder withApplicationTags(
  Set<String> applicationTags) {
 if (applicationTags != null) {
  appTags = parseQueries(applicationTags, false);
 }
 return this;
}

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

@GET
@Path(RMWSConsts.APPS_APPID_APPATTEMPTS_APPATTEMPTID)
@Produces({ MediaType.APPLICATION_JSON + "; " + JettyUtils.UTF_8,
  MediaType.APPLICATION_XML + "; " + JettyUtils.UTF_8 })
@Override
public org.apache.hadoop.yarn.server.webapp.dao.AppAttemptInfo getAppAttempt(
  @Context HttpServletRequest req, @Context HttpServletResponse res,
  @PathParam(RMWSConsts.APPID) String appId,
  @PathParam(RMWSConsts.APPATTEMPTID) String appAttemptId) {
 initForReadableEndpoints(res);
 return super.getAppAttempt(req, res, appId, appAttemptId);
}

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

@GET
@Path("/apps/{appid}/appattempts/{appattemptid}/containers/{containerid}")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@Override
public ContainerInfo getContainer(@Context HttpServletRequest req,
  @Context HttpServletResponse res, @PathParam("appid") String appId,
  @PathParam("appattemptid") String appAttemptId,
  @PathParam("containerid") String containerId) {
 init(res);
 return super.getContainer(req, res, appId, appAttemptId, containerId);
}

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

public ContainerInfo getContainer(HttpServletRequest req,
  HttpServletResponse res, String appId, String appAttemptId,
  String containerId) {
 UserGroupInformation callerUGI = getUser(req);
 ApplicationId aid = parseApplicationId(appId);
 ApplicationAttemptId aaid = parseApplicationAttemptId(appAttemptId);
 final ContainerId cid = parseContainerId(containerId);
 validateIds(aid, aaid, cid);
 ContainerReport container = null;
 try {
  rewrapAndThrowException(e);

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

public AppInfo getApp(HttpServletRequest req, HttpServletResponse res,
  String appId) {
 UserGroupInformation callerUGI = getUser(req);
 final ApplicationId id = parseApplicationId(appId);
 ApplicationReport app = null;
 try {
  if (callerUGI == null) {
   GetApplicationReportRequest request =
     GetApplicationReportRequest.newInstance(id);
   app = appBaseProt.getApplicationReport(request).getApplicationReport();
  } else {
   app = callerUGI.doAs(
     new PrivilegedExceptionAction<ApplicationReport> () {
    @Override
    public ApplicationReport run() throws Exception {
     GetApplicationReportRequest request =
       GetApplicationReportRequest.newInstance(id);
     return appBaseProt.getApplicationReport(request).getApplicationReport();
    }
   });
  }
 } catch (Exception e) {
  rewrapAndThrowException(e);
 }
 if (app == null) {
  throw new NotFoundException("app with id: " + appId + " not found");
 }
 return new AppInfo(app);
}

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

String startedEnd, String finishBegin, String finishEnd,
 Set<String> applicationTypes) {
UserGroupInformation callerUGI = getUser(req);
boolean checkEnd = false;
boolean checkAppTypes = false;
Set<String> appTypes = parseQueries(applicationTypes, false);
if (!appTypes.isEmpty()) {
 checkAppTypes = true;
 statesQuery.add(stateQuery);
Set<String> appStates = parseQueries(statesQuery, true);
if (!appStates.isEmpty()) {
 checkAppStates = true;
 rewrapAndThrowException(e);

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

AppInfo appInfo;
try {
 appInfo = super.getApp(req, res, appId.toString());
} catch (Exception ex) {
  ContainerInfo containerInfo;
  try {
   containerInfo = super.getContainer(
     req, res, appId.toString(),
     containerId.getApplicationAttemptId().toString(),

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

@GET
@Path("/apps/{appid}/appattempts/{appattemptid}/containers")
@Produces({ MediaType.APPLICATION_JSON + "; " + JettyUtils.UTF_8,
  MediaType.APPLICATION_XML + "; " + JettyUtils.UTF_8 })
@Override
public ContainersInfo getContainers(@Context HttpServletRequest req,
  @Context HttpServletResponse res, @PathParam("appid") String appId,
  @PathParam("appattemptid") String appAttemptId) {
 initForReadableEndpoints(res);
 return super.getContainers(req, res, appId, appAttemptId);
}

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

@GET
@Path("/apps/{appid}")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@Override
public AppInfo getApp(@Context HttpServletRequest req,
  @Context HttpServletResponse res, @PathParam("appid") String appId) {
 init(res);
 return super.getApp(req, res, appId);
}

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

@GET
@Path("/apps/{appid}/appattempts")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@Override
public AppAttemptsInfo getAppAttempts(@Context HttpServletRequest req,
  @Context HttpServletResponse res, @PathParam("appid") String appId) {
 init(res);
 return super.getAppAttempts(req, res, appId);
}

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

@GET
@Path("/apps")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@Override
public AppsInfo getApps(@Context HttpServletRequest req,
  @Context HttpServletResponse res, @QueryParam("state") String stateQuery,
  @QueryParam("states") Set<String> statesQuery,
  @QueryParam("finalStatus") String finalStatusQuery,
  @QueryParam("user") String userQuery,
  @QueryParam("queue") String queueQuery,
  @QueryParam("limit") String count,
  @QueryParam("startedTimeBegin") String startedBegin,
  @QueryParam("startedTimeEnd") String startedEnd,
  @QueryParam("finishedTimeBegin") String finishBegin,
  @QueryParam("finishedTimeEnd") String finishEnd,
  @QueryParam("applicationTypes") Set<String> applicationTypes) {
 init(res);
 validateStates(stateQuery, statesQuery);
 return super.getApps(req, res, stateQuery, statesQuery, finalStatusQuery,
  userQuery, queueQuery, count, startedBegin, startedEnd, finishBegin,
  finishEnd, applicationTypes);
}

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

public ContainerInfo getContainer(HttpServletRequest req,
  HttpServletResponse res, String appId, String appAttemptId,
  String containerId) {
 UserGroupInformation callerUGI = getUser(req);
 ApplicationId aid = parseApplicationId(appId);
 ApplicationAttemptId aaid = parseApplicationAttemptId(appAttemptId);
 final ContainerId cid = parseContainerId(containerId);
 validateIds(aid, aaid, cid);
 ContainerReport container = null;
 try {
  rewrapAndThrowException(e);

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

public AppInfo getApp(HttpServletRequest req, HttpServletResponse res,
  String appId) {
 UserGroupInformation callerUGI = getUser(req);
 final ApplicationId id = parseApplicationId(appId);
 ApplicationReport app = null;
 try {
  if (callerUGI == null) {
   GetApplicationReportRequest request =
     GetApplicationReportRequest.newInstance(id);
   app = appBaseProt.getApplicationReport(request).getApplicationReport();
  } else {
   app = callerUGI.doAs(
     new PrivilegedExceptionAction<ApplicationReport> () {
    @Override
    public ApplicationReport run() throws Exception {
     GetApplicationReportRequest request =
       GetApplicationReportRequest.newInstance(id);
     return appBaseProt.getApplicationReport(request).getApplicationReport();
    }
   });
  }
 } catch (Exception e) {
  rewrapAndThrowException(e);
 }
 if (app == null) {
  throw new NotFoundException("app with id: " + appId + " not found");
 }
 return new AppInfo(app);
}

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

String startedEnd, String finishBegin, String finishEnd,
 Set<String> applicationTypes) {
UserGroupInformation callerUGI = getUser(req);
boolean checkStart = false;
boolean checkEnd = false;
Set<String> appTypes = parseQueries(applicationTypes, false);
if (!appTypes.isEmpty()) {
 checkAppTypes = true;
 statesQuery.add(stateQuery);
Set<String> appStates = parseQueries(statesQuery, true);
if (!appStates.isEmpty()) {
 checkAppStates = true;
 rewrapAndThrowException(e);

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

AppInfo appInfo;
try {
 appInfo = super.getApp(req, res, appId.toString());
} catch (Exception ex) {
  ContainerInfo containerInfo;
  try {
   containerInfo = super.getContainer(
     req, res, appId.toString(),
     containerId.getApplicationAttemptId().toString(),

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

@GET
@Path(RMWSConsts.APPS_APPID_APPATTEMPTS_APPATTEMPTID_CONTAINERS)
@Produces({ MediaType.APPLICATION_JSON + "; " + JettyUtils.UTF_8,
  MediaType.APPLICATION_XML + "; " + JettyUtils.UTF_8 })
@Override
public ContainersInfo getContainers(@Context HttpServletRequest req,
  @Context HttpServletResponse res,
  @PathParam(RMWSConsts.APPID) String appId,
  @PathParam(RMWSConsts.APPATTEMPTID) String appAttemptId) {
 initForReadableEndpoints(res);
 return super.getContainers(req, res, appId, appAttemptId);
}

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

@GET
@Path("/apps/{appid}")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@Override
public AppInfo getApp(@Context HttpServletRequest req,
  @Context HttpServletResponse res, @PathParam("appid") String appId) {
 init(res);
 return super.getApp(req, res, appId);
}

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

@GET
@Path("/apps/{appid}/appattempts")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@Override
public AppAttemptsInfo getAppAttempts(@Context HttpServletRequest req,
  @Context HttpServletResponse res, @PathParam("appid") String appId) {
 init(res);
 return super.getAppAttempts(req, res, appId);
}

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

@GET
@Path("/apps")
@Produces({ MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML })
@Override
public AppsInfo getApps(@Context HttpServletRequest req,
  @Context HttpServletResponse res, @QueryParam("state") String stateQuery,
  @QueryParam("states") Set<String> statesQuery,
  @QueryParam("finalStatus") String finalStatusQuery,
  @QueryParam("user") String userQuery,
  @QueryParam("queue") String queueQuery,
  @QueryParam("limit") String count,
  @QueryParam("startedTimeBegin") String startedBegin,
  @QueryParam("startedTimeEnd") String startedEnd,
  @QueryParam("finishedTimeBegin") String finishBegin,
  @QueryParam("finishedTimeEnd") String finishEnd,
  @QueryParam("applicationTypes") Set<String> applicationTypes) {
 init(res);
 validateStates(stateQuery, statesQuery);
 return super.getApps(req, res, stateQuery, statesQuery, finalStatusQuery,
  userQuery, queueQuery, count, startedBegin, startedEnd, finishBegin,
  finishEnd, applicationTypes);
}

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

public ContainerInfo getContainer(HttpServletRequest req,
  HttpServletResponse res, String appId, String appAttemptId,
  String containerId) {
 UserGroupInformation callerUGI = getUser(req);
 ApplicationId aid = parseApplicationId(appId);
 ApplicationAttemptId aaid = parseApplicationAttemptId(appAttemptId);
 final ContainerId cid = parseContainerId(containerId);
 validateIds(aid, aaid, cid);
 ContainerReport container = null;
 try {
  rewrapAndThrowException(e);

内容来源于网络，如有侵权，请联系作者删除！

WebServices

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com