com.google.datastore.v1.Query.newBuilder()方法的使用及代码示例

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

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

Query.newBuilder介绍

暂无

代码示例

代码示例来源：origin: googleapis/google-cloud-java

@java.lang.Override
public Builder newBuilderForType() {
 return newBuilder();
}

代码示例来源：origin: googleapis/google-cloud-java

/**
 *
 *
 * <pre>
 * The parsed form of the `GqlQuery` from the request, if it was set.
 * </pre>
 *
 * <code>.google.datastore.v1.Query query = 2;</code>
 */
public Builder mergeQuery(com.google.datastore.v1.Query value) {
 if (queryBuilder_ == null) {
  if (query_ != null) {
   query_ = com.google.datastore.v1.Query.newBuilder(query_).mergeFrom(value).buildPartial();
  } else {
   query_ = value;
  }
  onChanged();
 } else {
  queryBuilder_.mergeFrom(value);
 }
 return this;
}
/**

代码示例来源：origin: googleapis/google-cloud-java

&& queryType_ != com.google.datastore.v1.Query.getDefaultInstance()) {
queryType_ =
  com.google.datastore.v1.Query.newBuilder((com.google.datastore.v1.Query) queryType_)
    .mergeFrom(value)
    .buildPartial();

代码示例来源：origin: googleapis/google-cloud-java

com.google.datastore.v1.Query toPb() {
 com.google.datastore.v1.Query.Builder queryPb = com.google.datastore.v1.Query.newBuilder();
 if (kind != null) {
  queryPb.addKindBuilder().setName(kind);

代码示例来源：origin: com.google.api.grpc/proto-google-cloud-datastore-v1

@java.lang.Override
public Builder newBuilderForType() {
 return newBuilder();
}

代码示例来源：origin: com.google.cloud.datastore/datastore-v1-protos

public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder() {

代码示例来源：origin: spotify/async-datastore-client

Query() {
 query = com.google.datastore.v1.Query.newBuilder();
 filters = Lists.newArrayList();
}

代码示例来源：origin: com.google.cloud.datastore/datastore-v1-protos

/**
 * <pre>
 * The query to run.
 * </pre>
 *
 * <code>optional .google.datastore.v1.Query query = 3;</code>
 */
public Builder mergeQuery(com.google.datastore.v1.Query value) {
 if (queryBuilder_ == null) {
  if (queryTypeCase_ == 3 &&
    queryType_ != com.google.datastore.v1.Query.getDefaultInstance()) {
   queryType_ = com.google.datastore.v1.Query.newBuilder((com.google.datastore.v1.Query) queryType_)
     .mergeFrom(value).buildPartial();
  } else {
   queryType_ = value;
  }
  onChanged();
 } else {
  if (queryTypeCase_ == 3) {
   queryBuilder_.mergeFrom(value);
  }
  queryBuilder_.setMessage(value);
 }
 queryTypeCase_ = 3;
 return this;
}
/**

代码示例来源：origin: GoogleCloudPlatform/google-cloud-datastore

/**
 * List the greetings in the specified guestbook.
 */
private void listGreetings(String guestbookName) throws DatastoreException {
 Query.Builder query = Query.newBuilder();
 query.addKindBuilder().setName(GREETING_KIND);
 query.setFilter(makeFilter(KEY_PROPERTY, PropertyFilter.Operator.HAS_ANCESTOR,
   makeValue(makeKey(GUESTBOOK_KIND, guestbookName))));
 query.addOrder(makeOrder(DATE_PROPERTY, PropertyOrder.Direction.DESCENDING));
 List<Entity> greetings = runQuery(query.build());
 if (greetings.size() == 0) {
  System.out.println("no greetings in " + guestbookName);
 }
 for (Entity greeting : greetings) {
  Map<String, Value> propertyMap = greeting.getProperties();
  System.out.println(
    DatastoreHelper.toDate(propertyMap.get(DATE_PROPERTY)) + ": " +
    DatastoreHelper.getString(propertyMap.get(USER_PROPERTY)) + " says " +
    DatastoreHelper.getString(propertyMap.get(MESSAGE_PROPERTY)));
 }
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

/** Generate dummy query splits. */
private List<Query> splitQuery(Query query, int numSplits) {
 List<Query> queries = new ArrayList<>();
 int offsetOfOriginal = query.getOffset();
 for (int i = 0; i < numSplits; i++) {
  Query.Builder q = Query.newBuilder();
  q.addKindBuilder().setName(KIND);
  // Making sub-queries unique (and not equal to the original query) by setting different
  // offsets.
  q.setOffset(++offsetOfOriginal);
  queries.add(q.build());
 }
 return queries;
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

/** Helper function to run a test reading from a {@link ReadFn}. */
private void readFnTest(int numEntities) throws Exception {
 // An empty query to read entities.
 Query query =
   Query.newBuilder().setLimit(Int32Value.newBuilder().setValue(numEntities)).build();
 // Use mockResponseForQuery to generate results.
 when(mockDatastore.runQuery(any(RunQueryRequest.class)))
   .thenAnswer(
     invocationOnMock -> {
      Query q = ((RunQueryRequest) invocationOnMock.getArguments()[0]).getQuery();
      return mockResponseForQuery(q);
     });
 ReadFn readFn = new ReadFn(V_1_OPTIONS, mockDatastoreFactory);
 DoFnTester<Query, Entity> doFnTester = DoFnTester.of(readFn);
 /**
  * Although Datastore client is marked transient in {@link ReadFn}, when injected through mock
  * factory using a when clause for unit testing purposes, it is not serializable because it
  * doesn't have a no-arg constructor. Thus disabling the cloning to prevent the test object from
  * being serialized.
  */
 doFnTester.setCloningBehavior(CloningBehavior.DO_NOT_CLONE);
 List<Entity> entities = doFnTester.processBundle(query);
 int expectedNumCallsToRunQuery = (int) Math.ceil((double) numEntities / QUERY_BATCH_LIMIT);
 verify(mockDatastore, times(expectedNumCallsToRunQuery)).runQuery(any(RunQueryRequest.class));
 // Validate the number of results.
 assertEquals(numEntities, entities.size());
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

/** A helper method to test {@link SplitQueryFn} to generate the expected number of splits. */
private void testSplitQueryFn(
  String projectId, String kind, @Nullable String namespace, int expectedNumSplits)
  throws Exception {
 Query.Builder query = Query.newBuilder();
 query.addKindBuilder().setName(kind);
 SplitQueryFn splitQueryFn = new SplitQueryFn(V1Options.from(projectId, namespace, null), 0);
 DoFnTester<Query, Query> doFnTester = DoFnTester.of(splitQueryFn);
 List<Query> queries = doFnTester.processBundle(query.build());
 assertEquals(expectedNumSplits, queries.size());
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

/** Build a datastore ancestor query for the specified kind, namespace and ancestor. */
static Query makeAncestorKindQuery(String kind, @Nullable String namespace, String ancestor) {
 Query.Builder q = Query.newBuilder();
 q.addKindBuilder().setName(kind);
 q.setFilter(
   makeFilter(
     "__key__",
     PropertyFilter.Operator.HAS_ANCESTOR,
     makeValue(makeAncestorKey(namespace, kind, ancestor))));
 return q.build();
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

/** Tests that {@link ReadFn} retries after an error. */
@Test
public void testReadFnRetriesErrors() throws Exception {
 // An empty query to read entities.
 Query query = Query.newBuilder().setLimit(Int32Value.newBuilder().setValue(1)).build();
 // Use mockResponseForQuery to generate results.
 when(mockDatastore.runQuery(any(RunQueryRequest.class)))
   .thenThrow(new DatastoreException("RunQuery", Code.DEADLINE_EXCEEDED, "", null))
   .thenAnswer(
     invocationOnMock -> {
      Query q = ((RunQueryRequest) invocationOnMock.getArguments()[0]).getQuery();
      return mockResponseForQuery(q);
     });
 ReadFn readFn = new ReadFn(V_1_OPTIONS, mockDatastoreFactory);
 DoFnTester<Query, Entity> doFnTester = DoFnTester.of(readFn);
 doFnTester.setCloningBehavior(CloningBehavior.DO_NOT_CLONE);
 doFnTester.processBundle(query);
}

代码示例来源：origin: GoogleCloudPlatform/google-cloud-datastore

/**
 * Creates a scatter query from the given user query
 *
 * @param query the user's query.
 * @param numSplits the number of splits to create.
 */
private Query.Builder createScatterQuery(Query query, int numSplits) {
 // TODO(pcostello): We can potentially support better splits with equality filters in our query
 // if there exists a composite index on property, __scatter__, __key__. Until an API for
 // metadata exists, this isn't possible. Note that ancestor and inequality queries fall into
 // the same category.
 Query.Builder scatterPointQuery = Query.newBuilder();
 scatterPointQuery.addAllKind(query.getKindList());
 scatterPointQuery.addOrder(DatastoreHelper.makeOrder(
   DatastoreHelper.SCATTER_PROPERTY_NAME, Direction.ASCENDING));
 // There is a split containing entities before and after each scatter entity:
 // ||---*------*------*------*------*------*------*---||  = scatter entity
 // If we represent each split as a region before a scatter entity, there is an extra region
 // following the last scatter point. Thus, we do not need the scatter entities for the last
 // region.
 scatterPointQuery.getLimitBuilder().setValue((numSplits - 1) * KEYS_PER_SPLIT);
 scatterPointQuery.addProjection(Projection.newBuilder().setProperty(
   PropertyReference.newBuilder().setName("__key__")));
 return scatterPointQuery;
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

@Test
public void testSourcePrimitiveDisplayData() {
 DisplayDataEvaluator evaluator = DisplayDataEvaluator.create();
 int numSplits = 98;
 PTransform<PBegin, PCollection<Entity>> read =
   DatastoreIO.v1()
     .read()
     .withProjectId(PROJECT_ID)
     .withQuery(Query.newBuilder().build())
     .withNumQuerySplits(numSplits);
 String assertMessage = "DatastoreIO read should include the '%s' in its primitive display data";
 Set<DisplayData> displayData = evaluator.displayDataForPrimitiveSourceTransforms(read);
 assertThat(
   String.format(assertMessage, "project id"),
   displayData,
   hasItem(hasDisplayItem("projectId", PROJECT_ID)));
 assertThat(
   String.format(assertMessage, "number of query splits"),
   displayData,
   hasItem(hasDisplayItem("numQuerySplits", numSplits)));
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

@Test
public void testReadValidationFailsQueryLimitZero() throws Exception {
 Query invalidLimit = Query.newBuilder().setLimit(Int32Value.newBuilder().setValue(0)).build();
 thrown.expect(IllegalArgumentException.class);
 thrown.expectMessage("Invalid query limit 0: must be positive");
 DatastoreIO.v1().read().withQuery(invalidLimit);
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

@Test
public void testReadValidationFailsQueryLimitNegative() throws Exception {
 Query invalidLimit = Query.newBuilder().setLimit(Int32Value.newBuilder().setValue(-5)).build();
 thrown.expect(IllegalArgumentException.class);
 thrown.expectMessage("Invalid query limit -5: must be positive");
 DatastoreIO.v1().read().withQuery(invalidLimit);
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

/** Builds a latest timestamp statistics query. */
private static Query makeLatestTimestampQuery(String namespace) {
 Query.Builder timestampQuery = Query.newBuilder();
 if (namespace == null) {
  timestampQuery.addKindBuilder().setName("__Stat_Total__");
 } else {
  timestampQuery.addKindBuilder().setName("__Stat_Ns_Total__");
 }
 timestampQuery.addOrder(makeOrder("timestamp", DESCENDING));
 timestampQuery.setLimit(Int32Value.newBuilder().setValue(1));
 return timestampQuery.build();
}

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-google-cloud-platform

/** Builds a per-kind statistics query for the given timestamp and namespace. */
private static Query makeStatKindQuery(String namespace, long timestamp) {
 Query.Builder statQuery = Query.newBuilder();
 if (namespace == null) {
  statQuery.addKindBuilder().setName("__Stat_Kind__");
 } else {
  statQuery.addKindBuilder().setName("__Stat_Ns_Kind__");
 }
 statQuery.setFilter(
   makeAndFilter(
     makeFilter("kind_name", EQUAL, makeValue(KIND).build()).build(),
     makeFilter("timestamp", EQUAL, makeValue(timestamp * 1000000L).build()).build()));
 return statQuery.build();
}

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

query

相关文章

    查看更多

    热门标签

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

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com