本文整理了Java中org.apache.lens.server.api.query.QueryContext.getEndTime
方法的一些代码示例,展示了QueryContext.getEndTime
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryContext.getEndTime
方法的具体详情如下:
包路径:org.apache.lens.server.api.query.QueryContext
类名称:QueryContext
方法名:getEndTime
暂无
代码示例来源:origin: org.apache.lens/lens-server-api
public QuerySuccess(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState) {
this(ctx, ctx.getEndTime(), prevState, currState, ctx.getQueryHandle());
}
}
代码示例来源:origin: apache/lens
public QuerySuccess(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState) {
this(ctx, ctx.getEndTime(), prevState, currState, ctx.getQueryHandle());
}
}
代码示例来源:origin: org.apache.lens/lens-server-api
public QueryCancelled(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause) {
// TODO: correct username. put who cancelled it, not the submitter. Similar for others
this(ctx, ctx.getEndTime(), prevState, currState, ctx.getQueryHandle(), ctx.getSubmittedUser(), cause);
}
}
代码示例来源:origin: apache/lens
public QueryCancelled(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause) {
// TODO: correct username. put who cancelled it, not the submitter. Similar for others
this(ctx, ctx.getEndTime(), prevState, currState, ctx.getQueryHandle(), ctx.getSubmittedUser(), cause);
}
}
代码示例来源:origin: apache/lens
public QueryFailed(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause) {
this(ctx, ctx.getEndTime(), prevState, currState, ctx.getQueryHandle(), ctx.getSubmittedUser(), cause);
}
}
代码示例来源:origin: org.apache.lens/lens-server-api
public QueryFailed(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause) {
this(ctx, ctx.getEndTime(), prevState, currState, ctx.getQueryHandle(), ctx.getSubmittedUser(), cause);
}
}
代码示例来源:origin: apache/lens
/**
* Instantiates a new finished query.
*
* @param ctx the ctx
*/
FinishedQuery(QueryContext ctx) {
this.ctx = ctx;
if (ctx.getEndTime() == 0) {
this.finishTime = new Date();
ctx.setEndTime(this.finishTime.getTime());
} else {
this.finishTime = new Date(ctx.getEndTime());
}
if (ctx.isResultAvailableInDriver()) {
try {
driverRS = ctx.getSelectedDriver().fetchResultSet(getCtx());
} catch (Exception e) {
log.error(
"Error while getting result set form driver {}. Driver result set based purging logic will be ignored",
ctx.getSelectedDriver(), e);
}
}
}
public boolean canBePurged() {
代码示例来源:origin: apache/lens
return;
event.setEndTime(ctx.getEndTime());
event.setStartTime(ctx.getLaunchTime());
event.setStatus(ctx.getStatus());
代码示例来源:origin: org.apache.lens/lens-server-api
this.submissionTime = ctx.getSubmissionTime();
this.startTime = ctx.getLaunchTime();
this.endTime = ctx.getEndTime();
this.result = ctx.getResultSetPath();
this.status = ctx.getStatus().getStatus().name();
代码示例来源:origin: apache/lens
this.submissionTime = ctx.getSubmissionTime();
this.startTime = ctx.getLaunchTime();
this.endTime = ctx.getEndTime();
this.result = ctx.getResultSetPath();
this.status = ctx.getStatus().getStatus().name();
内容来源于网络,如有侵权,请联系作者删除!