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

QueryContext.getQueryName介绍

暂无

代码示例

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

private String getQueryResultFileName() {
 String pathStr = Strings.isNullOrEmpty(ctx.getQueryName()) ? ""
  : LensFileOutputFormat.getValidOutputFileName(ctx.getQueryName()) + "-";
 return pathStr + ctx.getQueryHandle().toString() + PART_SUFFIX + currentPart + resultFileExtn;
}

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

private String getQueryResultFileName() {
 String pathStr = Strings.isNullOrEmpty(ctx.getQueryName()) ? ""
  : LensFileOutputFormat.getValidOutputFileName(ctx.getQueryName()) + "-";
 return pathStr + ctx.getQueryHandle().toString() + PART_SUFFIX + currentPart + resultFileExtn;
}

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

private List<QueryHandle> getQueriesInMemory(Set<Status> statuses, String userName, String driver,
 String queryName, long fromTime, long toTime) throws LensException {
 userName = UtilityMethods.removeDomain(userName);
 boolean filterByQueryName = StringUtils.isNotBlank(queryName);
 if (filterByQueryName) {
  queryName = queryName.toLowerCase();
 }
 boolean filterByDriver = StringUtils.isNotBlank(driver);
 List<QueryHandle> all = new ArrayList<QueryHandle>(allQueries.keySet());
 Iterator<QueryHandle> itr = all.iterator();
 while (itr.hasNext()) {
  QueryHandle q = itr.next();
  QueryContext context = allQueries.get(q);
  long querySubmitTime = context.getSubmissionTime();
  if ((!statuses.contains(context.getStatus().getStatus()))
   || (filterByQueryName && !context.getQueryName().toLowerCase().contains(queryName))
   || (filterByDriver && !context.getSelectedDriver().getFullyQualifiedName().equalsIgnoreCase(driver))
   || (!"all".equalsIgnoreCase(userName) && !userName.equalsIgnoreCase(context.getSubmittedUser()))
   || (!(fromTime <= querySubmitTime && querySubmitTime < toTime))) {
   itr.remove();
  }
 }
 return all;
}

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

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

/**
 * Returns the query handle if the same query is already launched by the user
 * in the same session.
 *
 * @param query
 * @param sessionHandle
 * @param conf
 * @param queryName
 * @return
 */
private QueryHandle checkForDuplicateQuery(String query, LensSessionHandle sessionHandle, Configuration conf,
  String queryName) {
 // Get all active queries of this session.
 List<QueryHandle> activeQueries = getSession(sessionHandle).getActiveQueries();
 synchronized (activeQueries) {
  for (QueryHandle handle : activeQueries) {
   QueryContext context = allQueries.get(handle);
   if (queryName.equals(context.getQueryName()) && query.equals(context.getUserQuery())
     && Arrays.equals(UtilityMethods.generateHashOfWritable(conf), context.getQueryConfHash())) {
    return handle;
   }
  }
 }
 return null;
}

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

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

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

String queryName = queryContext.getQueryName();
String mailSubject = "Query " + (StringUtils.isBlank(queryName) ? "" : (queryName + " "))
 + queryContext.getStatus().getStatus() + ": " + event.getQueryHandle();

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

this.driverStartTime = ctx.getDriverStatus().getDriverStartTime();
this.driverEndTime = ctx.getDriverStatus().getDriverFinishTime();
if (ctx.getQueryName() != null) {
 this.queryName = ctx.getQueryName().toLowerCase();

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

this.driverStartTime = ctx.getDriverStatus().getDriverStartTime();
this.driverEndTime = ctx.getDriverStatus().getDriverFinishTime();
if (ctx.getQueryName() != null) {
 this.queryName = ctx.getQueryName().toLowerCase();