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

QueryTask.<init>介绍

暂无

代码示例

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

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

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

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: vmware/xenon

@Test
public void hasResults() {
  assertFalse(QueryResultsProcessor.create(new QueryTask()).hasResults());
  QueryTask task = new QueryTask();
  task.results = new ServiceDocumentQueryResult();
  task.results.documents = new HashMap<>();
  task.results.documentCount = 1L;
  task.results.documents.put("link", new ServiceDocument());
  assertTrue(QueryResultsProcessor.create(task).hasResults());
}

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

@Test
public void hasResults() {
  assertFalse(QueryResultsProcessor.create(new QueryTask()).hasResults());
  QueryTask task = new QueryTask();
  task.results = new ServiceDocumentQueryResult();
  task.results.documents = new HashMap<>();
  task.results.documentCount = 1L;
  task.results.documents.put("link", new ServiceDocument());
  assertTrue(QueryResultsProcessor.create(task).hasResults());
}

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

private void failTask(Throwable e, Operation directOp, CompletionHandler c) {
  QueryTask t = new QueryTask();
  // self patch to failure
  t.taskInfo.stage = TaskStage.FAILED;
  t.taskInfo.failure = Utils.toServiceErrorResponse(e);
  if (directOp != null) {
    directOp.setBody(t).fail(e);
    return;
  }
  sendRequest(Operation.createPatch(getUri()).setBody(t).setCompletion(c));
}

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

private void failTask(Throwable e, Operation directOp, Operation.CompletionHandler c) {
  QueryTask t = new QueryTask();
  // self patch to failure
  t.taskInfo.stage = TaskState.TaskStage.FAILED;
  t.taskInfo.failure = Utils.toServiceErrorResponse(e);
  if (directOp != null) {
    directOp.setBody(t).fail(e);
    return;
  }
  sendRequest(Operation.createPatch(getUri()).setBody(t).setCompletion(c));
}

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

public <T extends TaskService.TaskServiceState> T getServiceStateUsingQueryTask(
    Class<T> type, String uri) {
  QueryTask.Query q = QueryTask.Query.Builder.create()
      .setTerm(ServiceDocument.FIELD_NAME_SELF_LINK, uri)
      .build();
  QueryTask queryTask = new QueryTask();
  queryTask.querySpec = new QueryTask.QuerySpecification();
  queryTask.querySpec.query = q;
  queryTask.querySpec.options.add(QueryOption.EXPAND_CONTENT);
  this.createQueryTaskService(null, queryTask, false, true, queryTask, null);
  return Utils.fromJson(queryTask.results.documents.get(uri), type);
}

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

@Test
public void selectedDocumentsNull() throws Exception {
  assertNotNull(
      QueryResultsProcessor.create(new QueryTask()).selectedDocuments(ServiceDocument.class));
}

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

@Test
public void fromTask() throws Exception {
  QueryTask task = new QueryTask();
  QueryResultsProcessor results = QueryResultsProcessor.create(task);
  assertSame(task, results.getQueryTask());
}

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

@Test
  public void documentsNull() throws Exception {
    assertNotNull(QueryResultsProcessor.create(new QueryTask()).documents(ServiceDocument.class));
  }
}

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

@Test
public void selectedDocumentNull() throws Exception {
  assertNull(QueryResultsProcessor.create(new QueryTask())
      .selectedDocument("id", ServiceDocument.class));
}

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

@Test
public void documentNull() throws Exception {
  assertNull(QueryResultsProcessor.create(new QueryTask()).document("id", ServiceDocument.class));
}

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

@Test
  public void documentsNull() throws Exception {
    assertNotNull(QueryResultsProcessor.create(new QueryTask()).documents(ServiceDocument.class));
  }
}

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

@Test
public void fromTask() throws Exception {
  QueryTask task = new QueryTask();
  QueryResultsProcessor results = QueryResultsProcessor.create(task);
  assertSame(task, results.getQueryTask());
}

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

@Test
public void selectedDocumentsNull() throws Exception {
  assertNotNull(
      QueryResultsProcessor.create(new QueryTask()).selectedDocuments(ServiceDocument.class));
}

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

@Test
public void selectedDocumentNull() throws Exception {
  assertNull(QueryResultsProcessor.create(new QueryTask())
      .selectedDocument("id", ServiceDocument.class));
}

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

@Test
public void fromOp() throws Exception {
  QueryTask task = new QueryTask();
  task.documentKind = QueryTask.KIND;
  Operation op = Operation.createGet(URI.create("/no/such/uri")).setBody(task);
  QueryResultsProcessor results = QueryResultsProcessor.create(op);
  assertNotNull(results.getQueryTask());
}

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

@Test
public void fromOp() throws Exception {
  QueryTask task = new QueryTask();
  task.documentKind = QueryTask.KIND;
  Operation op = Operation.createGet(URI.create("/no/such/uri")).setBody(task);
  QueryResultsProcessor results = QueryResultsProcessor.create(op);
  assertNotNull(results.getQueryTask());
}