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

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

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

QueryContext.getResultSetParentDir介绍

暂无

代码示例

代码示例来源:origin: org.apache.lens/lens-server-api

public Path getHDFSResultDir() {
 return new Path(new Path(getResultSetParentDir(), conf.get(LensConfConstants.QUERY_HDFS_OUTPUT_PATH,
  LensConfConstants.DEFAULT_HDFS_OUTPUT_PATH)), queryHandle.toString());
}

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

public Path getHDFSResultDir() {
 return new Path(new Path(getResultSetParentDir(), conf.get(LensConfConstants.QUERY_HDFS_OUTPUT_PATH,
  LensConfConstants.DEFAULT_HDFS_OUTPUT_PATH)), queryHandle.toString());
}

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

public void setupOutputs() throws IOException {
 resultFileExtn = ctx.getOuptutFileExtn();
 maxSplitRows = ctx.getMaxResultSplitRows();
 numRows = 0;
 String pathStr = ctx.getResultSetParentDir();
 if (StringUtils.isBlank(pathStr)) {
  throw new IllegalArgumentException("No output path specified");
 }
 String finalPathStr = Strings.isNullOrEmpty(ctx.getQueryName()) ? ""
  : LensFileOutputFormat.getValidOutputFileName(ctx.getQueryName()) + "-";
 finalPath = new Path(pathStr, finalPathStr + ctx.getQueryHandle().toString() + ".zip");
 tmpPath = new Path(pathStr, ctx.getQueryHandle().toString() + ".tmp.zip");
 fs = finalPath.getFileSystem(ctx.getConf());
 zipOut = new ZipOutputStream((fs.create(tmpPath)));
 ZipEntry zipEntry = new ZipEntry(getQueryResultFileName());
 zipOut.putNextEntry(zipEntry);
 encoding = ctx.getResultEncoding();
 // Write the UTF-16LE BOM (FF FE)
 if (encoding.equals(LensFileOutputFormat.UTF16LE)) {
  zipOut.write(0xFF);
  zipOut.write(0xFE);
  out = new OutputStreamWriter(zipOut, encoding);
 } else {
  out = new OutputStreamWriter(zipOut, encoding);
 }
}

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

numRows = 0;
String pathStr = ctx.getResultSetParentDir();
if (StringUtils.isBlank(pathStr)) {
 throw new IllegalArgumentException("No output path specified");

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

public void setupOutputs() throws IOException {
 String pathStr = ctx.getResultSetParentDir();
 if (StringUtils.isBlank(pathStr)) {
  throw new IllegalArgumentException("No output path specified");
 }
 String outputPathStr = Strings.isNullOrEmpty(ctx.getQueryName()) ? ""
  : LensFileOutputFormat.getValidOutputFileName(ctx.getQueryName()) + "-";
 outputPath = new Path(pathStr, outputPathStr + ctx.getQueryHandle().toString());
 Path tmpWorkPath = new Path(pathStr, ctx.getQueryHandle().toString() + ".tmp");
 try {
  rowWriter = LensFileOutputFormat.createRecordWriter(ctx.getConf(), tmpWorkPath, Reporter.NULL,
   ctx.getCompressOutput(), ctx.getOuptutFileExtn(), ctx.getResultEncoding());
  numRows=0;
 } catch (IOException e) {
  throw new IllegalArgumentException("Could not create tmp path");
 }
}

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

public void setupOutputs() throws IOException {
 String pathStr = ctx.getResultSetParentDir();
 if (StringUtils.isBlank(pathStr)) {
  throw new IllegalArgumentException("No output path specified");
 }
 String outputPathStr = Strings.isNullOrEmpty(ctx.getQueryName()) ? ""
  : LensFileOutputFormat.getValidOutputFileName(ctx.getQueryName()) + "-";
 outputPath = new Path(pathStr, outputPathStr + ctx.getQueryHandle().toString());
 Path tmpWorkPath = new Path(pathStr, ctx.getQueryHandle().toString() + ".tmp");
 try {
  rowWriter = LensFileOutputFormat.createRecordWriter(ctx.getConf(), tmpWorkPath, Reporter.NULL,
   ctx.getCompressOutput(), ctx.getOuptutFileExtn(), ctx.getResultEncoding());
  numRows=0;
 } catch (IOException e) {
  throw new IllegalArgumentException("Could not create tmp path");
 }
}

相关文章

微信公众号

最新文章

更多