本文整理了Java中org.apache.lens.server.api.query.QueryContext.getResultSetPath
方法的一些代码示例,展示了QueryContext.getResultSetPath
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryContext.getResultSetPath
方法的具体详情如下:
包路径:org.apache.lens.server.api.query.QueryContext
类名称:QueryContext
方法名:getResultSetPath
暂无
代码示例来源:origin: apache/lens
public static QueryEnded mockQueryEnded(SchedulerJobInstanceHandle instanceHandle, QueryStatus.Status status) {
QueryContext mockContext = PowerMockito.mock(QueryContext.class);
PowerMockito.when(mockContext.getResultSetPath()).thenReturn("/tmp/query1/result");
Configuration conf = new Configuration();
// set the instance handle
conf.set("job_instance_key", instanceHandle.getHandleIdString());
PowerMockito.when(mockContext.getConf()).thenReturn(conf);
// Get the queryHandle.
PowerMockito.when(mockContext.getQueryHandle()).thenReturn(new QueryHandle(UUID.randomUUID()));
QueryEnded queryEnded = PowerMockito.mock(QueryEnded.class);
PowerMockito.when(queryEnded.getQueryContext()).thenReturn(mockContext);
PowerMockito.when(queryEnded.getCurrentValue()).thenReturn(status);
return queryEnded;
}
}
代码示例来源:origin: apache/lens
latestRun.setResultPath(queryContext.getResultSetPath());
if (schedulerDAO.updateJobInstanceRun(latestRun) == 1) {
log.info("Updated instance run {} for instance {} for job {} to {}", latestRun.getRunId(), info.getId(),
代码示例来源:origin: apache/lens
event.setStatus(ctx.getStatus());
event.setCause(ended.getCause() != null ? ended.getCause() : "");
event.setResult(ctx.getResultSetPath());
event.setUserQuery(ctx.getUserQuery());
event.setSessionId(ctx.getLensSessionIdentifier());
代码示例来源:origin: org.apache.lens/lens-server-api
this.startTime = ctx.getLaunchTime();
this.endTime = ctx.getEndTime();
this.result = ctx.getResultSetPath();
this.status = ctx.getStatus().getStatus().name();
this.errorMessage = ctx.getStatus().getErrorMessage();
代码示例来源:origin: apache/lens
this.startTime = ctx.getLaunchTime();
this.endTime = ctx.getEndTime();
this.result = ctx.getResultSetPath();
this.status = ctx.getStatus().getStatus().name();
this.errorMessage = ctx.getStatus().getErrorMessage();
内容来源于网络,如有侵权,请联系作者删除!