org.apache.lens.server.api.query.QueryContext.setLaunchTime()方法的使用及代码示例

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

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

QueryContext.setLaunchTime介绍

暂无

代码示例

代码示例来源:origin: apache/lens

QueryLauncher(QueryContext query) {
 this.query = query;
 log.info("Query launcher created for query {} on driver {}", query.getQueryHandle(),
  query.getSelectedDriver().getFullyQualifiedName());
 query.setLaunchTime(System.currentTimeMillis());
}

代码示例来源:origin: org.apache.lens/lens-server-api

public QueryContext toQueryContext(Configuration conf, Collection<LensDriver> drivers) {
 if (null == selectedDriver && null != driverName) {
  selectedDriver = getDriverFromName(drivers);
 }
 QueryContext qctx =
  new QueryContext(userQuery, submitter, this.conf, conf, drivers, selectedDriver, submissionTime,
   false);
 qctx.setQueryHandle(QueryHandle.fromString(handle));
 qctx.setLaunchTime(this.startTime);
 qctx.setEndTime(getEndTime());
 qctx.setStatusSkippingTransitionTest(new QueryStatus(0.0, null, QueryStatus.Status.valueOf(getStatus()),
  null, getResult() != null, null, getErrorMessage() == null ? "" : getErrorMessage(), null));
 qctx.getDriverStatus().setDriverStartTime(getDriverStartTime());
 qctx.getDriverStatus().setDriverFinishTime(getDriverEndTime());
 qctx.setResultSetPath(getResult());
 qctx.setQueryName(getQueryName());
 if (null != driverQuery){
  qctx.setSelectedDriverQuery(driverQuery);
 }
 if (getPriority() != null) {
  qctx.setPriority(Priority.valueOf(getPriority()));
 }
 qctx.setFailedAttempts(getFailedAttempts());
 return qctx;
}

代码示例来源:origin: apache/lens

public QueryContext toQueryContext(Configuration conf, Collection<LensDriver> drivers) {
 if (null == selectedDriver && null != driverName) {
  selectedDriver = getDriverFromName(drivers);
 }
 QueryContext qctx =
  new QueryContext(userQuery, submitter, this.conf, conf, drivers, selectedDriver, submissionTime,
   false);
 qctx.setQueryHandle(QueryHandle.fromString(handle));
 qctx.setLaunchTime(this.startTime);
 qctx.setEndTime(getEndTime());
 qctx.setStatusSkippingTransitionTest(new QueryStatus(0.0, null, QueryStatus.Status.valueOf(getStatus()),
  null, getResult() != null, null, getErrorMessage() == null ? "" : getErrorMessage(), null));
 qctx.getDriverStatus().setDriverStartTime(getDriverStartTime());
 qctx.getDriverStatus().setDriverFinishTime(getDriverEndTime());
 qctx.setResultSetPath(getResult());
 qctx.setQueryName(getQueryName());
 if (null != driverQuery){
  qctx.setSelectedDriverQuery(driverQuery);
 }
 if (getPriority() != null) {
  qctx.setPriority(Priority.valueOf(getPriority()));
 }
 qctx.setFailedAttempts(getFailedAttempts());
 return qctx;
}

相关文章

微信公众号

最新文章

更多