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

QueryContext.setResultSetPath介绍

暂无

代码示例

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

@Override
public void commit() throws IOException {
 close();
 fs.rename(tmpPath, finalPath);
 finalPath = finalPath.makeQualified(fs);
 fileSize = fs.getFileStatus(finalPath).getLen();
 ctx.setResultSetPath(getFinalOutputPath());
}

代码示例来源：origin: org.apache.lens/lens-query-lib

@Override
public void commit() throws IOException {
 close();
 fs.rename(tmpPath, finalPath);
 finalPath = finalPath.makeQualified(fs);
 fileSize = fs.getFileStatus(finalPath).getLen();
 ctx.setResultSetPath(getFinalOutputPath());
}

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

@Override
public void commit() throws IOException {
 rowWriter.close(Reporter.NULL);
 if (outputPath != null && rowWriter.getTmpPath() != null) {
  FileSystem fs = outputPath.getFileSystem(ctx.getConf());
  finalPath = outputPath;
  if (rowWriter.getExtn() != null) {
   finalPath = new Path(outputPath + rowWriter.getExtn());
  }
  finalPath = finalPath.makeQualified(fs);
  fs.rename(rowWriter.getTmpPath(), finalPath);
  ctx.setResultSetPath(finalPath.toString());
  fileSize = fs.getFileStatus(finalPath).getLen();
 }
}

代码示例来源：origin: org.apache.lens/lens-query-lib

@Override
public void commit() throws IOException {
 rowWriter.close(Reporter.NULL);
 if (outputPath != null && rowWriter.getTmpPath() != null) {
  FileSystem fs = outputPath.getFileSystem(ctx.getConf());
  finalPath = outputPath;
  if (rowWriter.getExtn() != null) {
   finalPath = new Path(outputPath + rowWriter.getExtn());
  }
  finalPath = finalPath.makeQualified(fs);
  fs.rename(rowWriter.getTmpPath(), finalPath);
  ctx.setResultSetPath(finalPath.toString());
  fileSize = fs.getFileStatus(finalPath).getLen();
 }
}

代码示例来源：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;
}