本文整理了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
暂无
代码示例来源: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");
}
}
内容来源于网络,如有侵权,请联系作者删除!