com.vmware.xenon.services.common.QueryTask类的使用及代码示例

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

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

QueryTask介绍

暂无

代码示例

代码示例来源：origin: vmware/xenon

public static QueryTask create(QuerySpecification q) {
  QueryTask qt = new QueryTask();
  qt.querySpec = q;
  return qt;
}

代码示例来源：origin: vmware/xenon

private void verifyImplicitQueryPageSize(QueryTask.QuerySpecification querySpec, int pageSize) {
  LuceneDocumentIndexService.setImplicitQueryProcessingPageSize(pageSize);
  QueryTask qt = QueryTask.create(querySpec).setDirect(true);
  this.host.createQueryTaskService(qt, false, true, qt, null);
  assertEquals(this.serviceCount, qt.results.documentLinks.size());
}

代码示例来源：origin: vmware/xenon

public void logAllDocuments(Set<URI> baseHostUris) {
  QueryTask task = new QueryTask();
  task.setDirect(true);
  task.querySpec = new QuerySpecification();
  task.querySpec.query.setTermPropertyName("documentSelfLink").setTermMatchValue("*");
  task.querySpec.query.setTermMatchType(MatchType.WILDCARD);
  task.querySpec.options = EnumSet.of(QueryOption.EXPAND_CONTENT);
  List<Operation> ops = new ArrayList<>();
  for (URI baseHost : baseHostUris) {
    Operation queryPost = Operation
        .createPost(UriUtils.buildUri(baseHost, ServiceUriPaths.CORE_QUERY_TASKS))
        .setBody(task);
    ops.add(queryPost);
  }
  List<QueryTask> queryTasks = this.sender.sendAndWait(ops, QueryTask.class);
  for (QueryTask queryTask : queryTasks) {
    log(Utils.toJsonHtml(queryTask));
  }
}

代码示例来源：origin: vmware/xenon

@Override
public void handleGet(Operation get) {
  QuerySpecification clonedSpec = new QuerySpecification();
  // shallow copy specification
  this.spec.copyTo(clonedSpec);
  QueryTask task = QueryTask.create(clonedSpec);
  task.documentKind = KIND;
  task.documentSelfLink = this.documentSelfLink;
  task.documentExpirationTimeMicros = this.documentExpirationTimeMicros;
  task.taskInfo.stage = TaskStage.CREATED;
  task.taskInfo.isDirect = true;
  task.indexLink = this.indexLink;
  task.nodeSelectorLink = this.nodeSelectorPath;
  // the client can supply a URI parameter to modify the result limit. This
  // only affects the current GET operation and not the page service itself and any
  // future GETs from other clients. The generated nextPageLink, for this GET, will
  // of course be different than other operations with the original limit
  Integer limit = UriUtils.getODataLimitParamValue(get.getUri());
  if (limit != null) {
    task.querySpec.resultLimit = limit;
  }
  forwardToLucene(task, get);
}

代码示例来源：origin: vmware/xenon

private void createAndSendBroadcastQuery(QueryTask origQueryTask, Operation startPost) {
  QueryTask queryTask = Utils.clone(origQueryTask);
  queryTask.setDirect(true);

代码示例来源：origin: com.vmware.xenon/xenon-common

public void logAllDocuments(Set<URI> baseHostUris) {
  QueryTask task = new QueryTask();
  task.setDirect(true);
  task.querySpec = new QuerySpecification();
  task.querySpec.query.setTermPropertyName("documentSelfLink").setTermMatchValue("*");
  task.querySpec.query.setTermMatchType(MatchType.WILDCARD);
  task.querySpec.options = EnumSet.of(QueryOption.EXPAND_CONTENT);
  List<Operation> ops = new ArrayList<>();
  for (URI baseHost : baseHostUris) {
    Operation queryPost = Operation
        .createPost(UriUtils.buildUri(baseHost, ServiceUriPaths.CORE_QUERY_TASKS))
        .setBody(task);
    ops.add(queryPost);
  }
  List<QueryTask> queryTasks = this.sender.sendAndWait(ops, QueryTask.class);
  for (QueryTask queryTask : queryTasks) {
    log(Utils.toJsonHtml(queryTask));
  }
}

代码示例来源：origin: vmware/admiral

@Override
public void handleGet(Operation get) {
  QuerySpecification clonedSpec = new QuerySpecification();
  // shallow copy specification
  this.spec.copyTo(clonedSpec);
  QueryTask task = QueryTask.create(clonedSpec);
  task.documentKind = KIND;
  task.documentSelfLink = this.documentSelfLink;
  task.documentExpirationTimeMicros = this.documentExpirationTimeMicros;
  task.taskInfo.stage = TaskStage.CREATED;
  task.taskInfo.isDirect = true;
  task.indexLink = this.indexLink;
  task.nodeSelectorLink = this.nodeSelectorPath;
  // the client can supply a URI parameter to modify the result limit. This
  // only affects the current GET operation and not the page service itself and any
  // future GETs from other clients. The generated nextPageLink, for this GET, will
  // of course be different than other operations with the original limit
  Integer limit = UriUtils.getODataLimitParamValue(get.getUri());
  if (limit != null) {
    task.querySpec.resultLimit = limit;
  }
  forwardToPostgres(task, get);
}

代码示例来源：origin: vmware/xenon

return;
task.setDirect(true);
task.indexLink = this.documentIndexLink;

代码示例来源：origin: vmware/xenon

private Builder(boolean isDirect) {
  this.queryTask = new QueryTask();
  this.querySpec = new QuerySpecification();
  this.queryTask.querySpec = this.querySpec;
  this.queryTask.taskInfo.isDirect = isDirect;
}

代码示例来源：origin: com.vmware.xenon/xenon-common

private void verifyImplicitQueryPageSize(QueryTask.QuerySpecification querySpec, int pageSize,
    double expectedIterationCount) {
  LuceneDocumentIndexService.setImplicitQueryProcessingPageSize(pageSize);
  QueryTask qt = QueryTask.create(querySpec).setDirect(true);
  this.host.createQueryTaskService(qt, false, true, qt, null);
  assertEquals(qt.results.documentLinks.size(), this.serviceCount);
  ServiceStat st = getLuceneStat(LuceneDocumentIndexService.STAT_NAME_ITERATIONS_PER_QUERY);
  assertEquals(st.latestValue, expectedIterationCount, 0.01);
}

代码示例来源：origin: vmware/xenon

prepareRequest(query);
QueryTask countTask = new QueryTask();
countTask.setDirect(true);
countTask.querySpec = new QueryTask.QuerySpecification();
countTask.querySpec.options.add(QueryOption.COUNT);

代码示例来源：origin: vmware/xenon

@Test
public void handleStartErrors_exampleQueryTask() {
  ExampleTaskServiceState badState = new ExampleTaskServiceState();
  badState.exampleQueryTask = QueryTask.create(null);
  verifyExpectedHandleStartError(badState, "Do not specify exampleQueryTask: internal use only");
}

代码示例来源：origin: vmware/xenon

public static void failTask(Operation get, Throwable ex) {
  QueryTask t = new QueryTask();
  t.taskInfo.stage = TaskState.TaskStage.FAILED;
  t.taskInfo.failure = Utils.toServiceErrorResponse(ex);
  get.setBody(t).fail(ex);
}

代码示例来源：origin: com.vmware.xenon/xenon-common

QueryTask qt = QueryTask.create(q).setDirect(true);
  this.host.createQueryTaskService(qt, false, true, qt, null);
  return qt.results.documentCount >= serviceUris.size() * floor
QueryTask qt = QueryTask.create(q).setDirect(true);
this.host.createQueryTaskService(qt, false, true, qt, null);
HashMap<String, TreeSet<Integer>> aggregated = new HashMap<>();

代码示例来源：origin: vmware/xenon

return;
QueryTask queryTask = new QueryTask();
queryTask.querySpec = new QuerySpecification();
Query resourceGroupQuery = Builder.create()
queryTask.querySpec.query = resourceGroupQuery;
queryTask.querySpec.resultLimit = resultLimit;
queryTask.setDirect(true);
Operation postOp = Operation.createPost(s, ServiceUriPaths.CORE_LOCAL_QUERY_TASKS)
    .setBody(queryTask)

代码示例来源：origin: com.vmware.xenon/xenon-common

@Test
public void handleStartErrors_exampleQueryTask() {
  ExampleTaskServiceState badState = new ExampleTaskServiceState();
  badState.exampleQueryTask = QueryTask.create(null);
  verifyExpectedHandleStartError(badState, "Do not specify exampleQueryTask: internal use only");
}

代码示例来源：origin: vmware/xenon

private void cancelContinuousQueryOnIndex(QueryTask task) {
  QueryTask body = new QueryTask();
  body.documentSelfLink = task.documentSelfLink;
  body.taskInfo.stage = TaskStage.CANCELLED;
  body.querySpec = task.querySpec;
  body.documentKind = task.documentKind;
  Operation cancelActiveQueryPatch = Operation
      .createPatch(this, task.indexLink)
      .setBodyNoCloning(body);
  sendRequest(cancelActiveQueryPatch);
}

代码示例来源：origin: vmware/xenon

QueryTask qt = QueryTask.create(q).setDirect(true);
  this.host.createQueryTaskService(qt, false, true, qt, null);
  return qt.results.documentCount >= serviceUris.size() * floor
QueryTask qt = QueryTask.create(q).setDirect(true);
this.host.createQueryTaskService(qt, false, true, qt, null);
HashMap<String, TreeSet<Integer>> aggregated = new HashMap<>();

代码示例来源：origin: vmware/xenon

return;
QueryTask queryTask = new QueryTask();
queryTask.querySpec = new QuerySpecification();
queryTask.querySpec.query = userGroupState.query;
queryTask.querySpec.resultLimit = resultLimit;
queryTask.setDirect(true);
Operation postOp = Operation.createPost(s, ServiceUriPaths.CORE_LOCAL_QUERY_TASKS)
    .setBody(queryTask)

代码示例来源：origin: com.vmware.xenon/xenon-common

QueryTask task = QueryTask.create(q);
task.documentExpirationTimeMicros = exp;
task = QueryTask.create(q);
task.documentExpirationTimeMicros = exp;
taskURI = this.host.createQueryTaskService(task, false,
task = QueryTask.create(q);
task.documentExpirationTimeMicros = Utils.fromNowMicrosUtc(TimeUnit.SECONDS
    .toMicros(1));

内容来源于网络，如有侵权，请联系作者删除！

QueryTask

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com