com.google.cloud.bigtable.data.v2.models.Query.create()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(8.9k)|赞(0)|评价(0)|浏览(290)

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

Query.create介绍

[英]Constructs a new Query object for the specified table id. The table id will be combined with the instance name specified in the com.google.cloud.bigtable.data.v2.BigtableDataSettings.
[中]为指定的表id构造新的查询对象。该表id将与com中指定的实例名称组合。谷歌。云大桌子。数据v2。BigtableDataSettings。

代码示例

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

  1. @Test
  2. public void serializationTest() throws IOException, ClassNotFoundException {
  3.  Query expected = Query.create(TABLE_ID).filter(FILTERS.key().regex(".*"));
  4.  ByteArrayOutputStream bos = new ByteArrayOutputStream();
  5.  ObjectOutputStream oos = new ObjectOutputStream(bos);
  6.  oos.writeObject(expected);
  7.  oos.close();
  8.  ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(bos.toByteArray()));
  9.  Query actual = (Query) ois.readObject();
  10.  assertThat(actual.toProto(requestContext)).isEqualTo(expected.toProto(requestContext));
  11. }

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

  1. @Test
  2. public void proxyReadRowsAsyncTest() {
  3.  Query query = Query.create("fake-table");
  4.  @SuppressWarnings("unchecked")
  5.  ResponseObserver<Row> mockObserver = Mockito.mock(ResponseObserver.class);
  6.  bigtableDataClient.readRowsAsync(query, mockObserver);
  7.  Mockito.verify(mockReadRowsCallable).call(query, mockObserver);
  8. }

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

  1. @Test
  2. public void proxyReadRowsSyncTest() {
  3.  Query query = Query.create("fake-table");
  4.  bigtableDataClient.readRows(query);
  5.  Mockito.verify(mockReadRowsCallable).call(query);
  6. }

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

  1. @Test
  2. public void readRowTest() {
  3.  Row expectedRow =
  4.    Row.create(ByteString.copyFromUtf8("fake-row-key"), ImmutableList.<RowCell>of());
  5.  Mockito.when(mockReadRowCallable.futureCall(Query.create("fake-table").rowKey("fake-row-key")))
  6.    .thenReturn(ApiFutures.immediateFuture(expectedRow));
  7.  Row actualRow =
  8.    bigtableDataClient.readRow("fake-table", ByteString.copyFromUtf8("fake-row-key"));
  9.  assertThat(actualRow).isEqualTo(expectedRow);
  10. }

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

  1. @Test
  2. public void proxyReadRowAsyncTest() {
  3.  bigtableDataClient.readRowAsync("fake-table", ByteString.copyFromUtf8("fake-row-key"));
  4.  Mockito.verify(mockReadRowCallable)
  5.    .futureCall(Query.create("fake-table").rowKey("fake-row-key"));
  6. }

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

  1. @Test
  2. public void readRowStrTest() {
  3.  Row expectedRow =
  4.    Row.create(ByteString.copyFromUtf8("fake-row-key"), ImmutableList.<RowCell>of());
  5.  Mockito.when(mockReadRowCallable.futureCall(Query.create("fake-table").rowKey("fake-row-key")))
  6.    .thenReturn(ApiFutures.immediateFuture(expectedRow));
  7.  Row actualRow = bigtableDataClient.readRow("fake-table", "fake-row-key");
  8.  assertThat(actualRow).isEqualTo(expectedRow);
  9. }

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

  1. @Test
  2. public void testLimitAdded() {
  3.  ReadRowsFirstCallable<Row> callable = new ReadRowsFirstCallable<>(innerCallable);
  4.  innerResult.set(null);
  5.  callable.call(Query.create("fake-table"));
  6.  Truth.assertThat(innerQuery.getValue().toProto(REQUEST_CONTEXT))
  7.    .isEqualTo(Query.create("fake-table").limit(1).toProto(REQUEST_CONTEXT));
  8. }

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

  1. @Test
  2. public void readRowsTest() {
  3.  client.readRows(Query.create(TABLE_ID));
  4.  verifyHeaderSent();
  5. }

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

  1. @Test
  2. public void requestContextTest() {
  3.  Query query = Query.create(TABLE_ID);
  4.  ReadRowsRequest proto = query.toProto(requestContext);
  5.  assertThat(proto).isEqualTo(expectedProtoBuilder().build());
  6. }

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

  1. private void deleteRows() throws InterruptedException, ExecutionException, TimeoutException {
  2.  Query query = Query.create(tableId).prefix(rowPrefix);
  3.  List<ApiFuture<Void>> futures = Lists.newArrayList();
  4.  ServerStream<Row> rows = dataClient.readRows(query);
  5.  for (Row row : rows) {
  6.   ApiFuture<Void> future =
  7.     dataClient.mutateRowAsync(RowMutation.create(tableId, row.getKey()).deleteRow());
  8.   futures.add(future);
  9.  }
  10.  ApiFutures.allAsList(futures).get(10, TimeUnit.MINUTES);
  11. }

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

  1. @Test
  2. public void testRequestConverted() {
  3.  ServerStreamingStashCallable<ReadRowsRequest, Row> innerCallable =
  4.    new ServerStreamingStashCallable<>();
  5.  ReadRowsUserCallable<Row> callable = new ReadRowsUserCallable<>(innerCallable, REQUEST_CONTEXT);
  6.  Query query = Query.create("fake-table");
  7.  callable.call(query);
  8.  Truth.assertThat(innerCallable.getActualRequest()).isEqualTo(query.toProto(REQUEST_CONTEXT));
  9. }

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

  1. @Test
  2. public void fullTableScanTest() {
  3.  service.expectations.add(
  4.    RpcExpectation.create().respondWith("r1").respondWithStatus(Code.UNAVAILABLE));
  5.  service.expectations.add(
  6.    RpcExpectation.create().expectRequest(Range.greaterThan("r1")).respondWith("r2"));
  7.  List<String> actualResults = getResults(Query.create(TABLE_ID));
  8.  Truth.assertThat(actualResults).containsExactly("r1", "r2").inOrder();
  9. }

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

  1. @Test
  2. public void limitTest() {
  3.  Query query = Query.create(TABLE_ID).limit(10);
  4.  Builder expectedProto = expectedProtoBuilder().setRowsLimit(10);
  5.  ReadRowsRequest actualProto = query.toProto(requestContext);
  6.  assertThat(actualProto).isEqualTo(expectedProto.build());
  7. }

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

  1. @Test
  2. public void pointTest() {
  3.  service.expectations.add(
  4.    RpcExpectation.create()
  5.      .expectRequest("r1", "r2")
  6.      .respondWith("r1")
  7.      .respondWithStatus(Code.UNAVAILABLE));
  8.  service.expectations.add(RpcExpectation.create().expectRequest("r2").respondWith("r2"));
  9.  List<String> actualResults = getResults(Query.create(TABLE_ID).rowKey("r1").rowKey("r2"));
  10.  Truth.assertThat(actualResults).containsExactly("r1", "r2").inOrder();
  11. }

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

  1. @Test
  2. public void filterTest() {
  3.  Query query = Query.create(TABLE_ID).filter(FILTERS.key().regex(".*"));
  4.  Builder expectedProto =
  5.    expectedProtoBuilder()
  6.      .setFilter(RowFilter.newBuilder().setRowKeyRegexFilter(ByteString.copyFromUtf8(".*")));
  7.  ReadRowsRequest actualProto = query.toProto(requestContext);
  8.  assertThat(actualProto).isEqualTo(expectedProto.build());
  9. }

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

  1. @Test
  2. public void happyPathTest() {
  3.  service.expectations.add(
  4.    RpcExpectation.create()
  5.      .expectRequest("k1")
  6.      .expectRequest(Range.closedOpen("r1", "r3"))
  7.      .respondWith("k1", "r1", "r2"));
  8.  List<String> actualResults = getResults(Query.create(TABLE_ID).rowKey("k1").range("r1", "r3"));
  9.  Truth.assertThat(actualResults).containsExactly("k1", "r1", "r2").inOrder();
  10. }

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

  1. @Test
  2. public void errorAfterRequestCompleteTest() {
  3.  service.expectations.add(
  4.    RpcExpectation.create()
  5.      .expectRequest(Range.closedOpen("r1", "r3"))
  6.      .expectRequest("r4")
  7.      .respondWith("r2", "r4")
  8.      .respondWithStatus(Code.UNAVAILABLE));
  9.  // Second retry request is handled locally in ReadRowsRetryCompletedCallable
  10.  List<String> actualResults = getResults(Query.create(TABLE_ID).range("r1", "r3").rowKey("r4"));
  11.  Truth.assertThat(actualResults).containsExactly("r2", "r4");
  12. }

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

  1. @Test
  2. public void readRowFilterAsyncTest() {
  3.  // Build the filter expression
  4.  Filter filter =
  5.    FILTERS
  6.      .chain()
  7.      .filter(FILTERS.qualifier().regex("prefix.*"))
  8.      .filter(FILTERS.limit().cellsPerRow(10));
  9.  bigtableDataClient.readRowAsync("fake-table", ByteString.copyFromUtf8("fake-row-key"), filter);
  10.  Mockito.verify(mockReadRowCallable)
  11.    .futureCall(Query.create("fake-table").rowKey("fake-row-key").filter(filter));
  12. }

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

  1. @Test
  2.  public void testFirstIsLimited() {
  3.   ServerStreamingStashCallable<ReadRowsRequest, Row> innerCallable =
  4.     new ServerStreamingStashCallable<>();
  5.   ReadRowsUserCallable<Row> callable = new ReadRowsUserCallable<>(innerCallable, REQUEST_CONTEXT);
  6.   Query query = Query.create("fake-table");
  8.   callable.first().call(query);
  10.   Truth.assertThat(innerCallable.getActualRequest())
  11.     .isEqualTo(query.limit(1).toProto(REQUEST_CONTEXT));
  12.  }
  13. }

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

  1. @Test
  2. public void readRowFilterStrAsyncTest() {
  3.  // Build the filter expression
  4.  Filter filter =
  5.    FILTERS
  6.      .chain()
  7.      .filter(FILTERS.qualifier().regex("prefix.*"))
  8.      .filter(FILTERS.limit().cellsPerRow(10));
  9.  bigtableDataClient.readRowAsync("fake-table", "fake-row-key", filter);
  10.  Mockito.verify(mockReadRowCallable)
  11.    .futureCall(Query.create("fake-table").rowKey("fake-row-key").filter(filter));
  12. }

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

query

相关文章

    查看更多

    热门标签

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

    最新文章

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