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

QueryContext.getQueryHandle介绍

暂无

代码示例

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

public synchronized void setStatus(final QueryStatus newStatus) throws LensException {
 validateTransition(newStatus);
 log.info("Updating status of {} from {} to {}", getQueryHandle(), this.status, newStatus);
 this.status = newStatus;
}

代码示例来源：origin: org.apache.lens/lens-driver-es

@Override
public void executeAsync(final QueryContext context) {
 handleContextMap.put(context.getQueryHandle(), context);
 final Future<LensResultSet> futureResult
  = asyncQueryPool.submit(new ESQueryExecuteCallable(context, SessionState.get()));
 resultSetMap.put(context.getQueryHandle(), futureResult);
}

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

public QuerySuccess(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState) {
  this(ctx, ctx.getEndTime(), prevState, currState, ctx.getQueryHandle());
 }
}

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

@Override
public void executeAsync(final QueryContext context) {
 handleContextMap.put(context.getQueryHandle(), context);
 final Future<LensResultSet> futureResult
  = asyncQueryPool.submit(new ESQueryExecuteCallable(context, SessionState.get()));
 resultSetMap.put(context.getQueryHandle(), futureResult);
}

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

public synchronized void setStatus(final QueryStatus newStatus) throws LensException {
 validateTransition(newStatus);
 log.info("Updating status of {} from {} to {}", getQueryHandle(), this.status, newStatus);
 this.status = newStatus;
}

代码示例来源：origin: org.apache.lens/lens-driver-es

@Override
public LensResultSet execute(QueryContext context) throws LensException {
 handleContextMap.put(context.getQueryHandle(), context);
 final ESQuery esQuery = rewrite(context);
 final ESResultSet resultSet = esClient.execute(esQuery);
 context.setDriverStatus(DriverQueryStatus.DriverQueryState.SUCCESSFUL);
 handleContextMap.remove(context.getQueryHandle());
 return resultSet;
}

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

@Override
public LensResultSet execute(QueryContext context) throws LensException {
 handleContextMap.put(context.getQueryHandle(), context);
 final ESQuery esQuery = rewrite(context);
 final ESResultSet resultSet = esClient.execute(esQuery);
 context.setDriverStatus(DriverQueryStatus.DriverQueryState.SUCCESSFUL);
 handleContextMap.remove(context.getQueryHandle());
 return resultSet;
}

代码示例来源：origin: org.apache.lens/lens-driver-hive

@Override
public void registerForCompletionNotification(
 QueryContext context, long timeoutMillis, QueryCompletionListener listener) {
 Thread th = new Thread(new QueryCompletionNotifier(context.getQueryHandle(), timeoutMillis, listener));
 th.start();
}

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

@Override
public void registerForCompletionNotification(
 QueryContext context, long timeoutMillis, QueryCompletionListener listener) {
 Thread th = new Thread(new QueryCompletionNotifier(context.getQueryHandle(), timeoutMillis, listener));
 th.start();
}

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

public QueryCancelled(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause) {
  // TODO: correct username. put who cancelled it, not the submitter. Similar for others
  this(ctx, ctx.getEndTime(), prevState, currState, ctx.getQueryHandle(), ctx.getSubmittedUser(), cause);
 }
}

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

QueryLauncher(QueryContext query) {
 this.query = query;
 log.info("Query launcher created for query {} on driver {}", query.getQueryHandle(),
  query.getSelectedDriver().getFullyQualifiedName());
 query.setLaunchTime(System.currentTimeMillis());
}

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

public QueryClosed(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause) {
  this(ctx, ctx.getClosedTime(), prevState, currState, ctx.getQueryHandle(), ctx.getSubmittedUser(), cause);
 }
}

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

public QueryClosed(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause) {
  this(ctx, ctx.getClosedTime(), prevState, currState, ctx.getQueryHandle(), ctx.getSubmittedUser(), cause);
 }
}

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

public QueryCancelled(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause) {
  // TODO: correct username. put who cancelled it, not the submitter. Similar for others
  this(ctx, ctx.getEndTime(), prevState, currState, ctx.getQueryHandle(), ctx.getSubmittedUser(), cause);
 }
}

代码示例来源：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 String getQueryResultFileName() {
 String pathStr = Strings.isNullOrEmpty(ctx.getQueryName()) ? ""
  : LensFileOutputFormat.getValidOutputFileName(ctx.getQueryName()) + "-";
 return pathStr + ctx.getQueryHandle().toString() + PART_SUFFIX + currentPart + resultFileExtn;
}

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

public static QueryContext createQueryInstanceWithQueryHandleAndPriorityStubbing(String handlePrefix, int index,
                                       Priority priority) {
 QueryContext mockQuery = mock(QueryContext.class);
 when(mockQuery.getQueryHandle()).thenReturn(QueryHandle.fromString(handlePrefix + index));
 when(mockQuery.getPriority()).thenReturn(priority);
 return mockQuery;
}

代码示例来源：origin: org.apache.lens/lens-driver-jdbc

@Override
protected LensResultSet createResultSet(QueryContext ctx) throws LensException {
 checkConfigured();
 return getQueryContext(ctx.getQueryHandle()).getQueryResult().getLensResultSet(true);
}

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

@Override
protected LensResultSet createResultSet(QueryContext ctx) throws LensException {
 checkConfigured();
 return getQueryContext(ctx.getQueryHandle()).getQueryResult().getLensResultSet(true);
}

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

LensPersistentResult(QueryContext ctx, Configuration conf, LensConf qconf) {
 this(ctx.getQueryHandle(),
  ctx.getQueryOutputFormatter().getMetadata(),
  ctx.getQueryOutputFormatter().getFinalOutputPath(),
  ctx.getQueryOutputFormatter().getNumRows(),
  ctx.getQueryOutputFormatter().getFileSize(), conf, qconf);
}