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

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

本文整理了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

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();

相关文章

微信公众号

最新文章

更多