本文整理了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
暂无
代码示例来源: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;
}
内容来源于网络,如有侵权,请联系作者删除!