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

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

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

Query.toProto介绍

[英]Creates the request protobuf. This method is considered an internal implementation detail and not meant to be used by applications.
[中]创建请求protobuf。此方法被视为内部实现细节，不适用于应用程序。

代码示例

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

  1. @Override
  2. public void call(Query request, ResponseObserver<RowT> responseObserver, ApiCallContext context) {
  3.  ReadRowsRequest innerRequest = request.toProto(requestContext);
  4.  inner.call(innerRequest, responseObserver, context);
  5. }

代码示例来源：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 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 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. @Test
  2. public void rowKeysTest() {
  3.  Query query =
  4.    Query.create(TABLE_ID)
  5.      .rowKey("simple-string")
  6.      .rowKey(ByteString.copyFromUtf8("byte-string"));
  7.  ReadRowsRequest.Builder expectedProto = expectedProtoBuilder();
  8.  expectedProto
  9.    .getRowsBuilder()
  10.    .addRowKeys(ByteString.copyFromUtf8("simple-string"))
  11.    .addRowKeys(ByteString.copyFromUtf8("byte-string"));
  12.  ReadRowsRequest actualProto = query.toProto(requestContext);
  13.  assertThat(actualProto).isEqualTo(expectedProto.build());
  14. }

代码示例来源：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 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 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 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 rowRangeTest() {
  3.  Query query =
  4.    Query.create(TABLE_ID)
  5.      .range("simple-begin", "simple-end")
  6.      .range(ByteString.copyFromUtf8("byte-begin"), ByteString.copyFromUtf8("byte-end"))
  7.      .range(ByteStringRange.create("range-begin", "range-end"));
  8.  Builder expectedProto = expectedProtoBuilder();
  9.  expectedProto
  10.    .getRowsBuilder()
  11.    .addRowRanges(
  12.      RowRange.newBuilder()
  13.        .setStartKeyClosed(ByteString.copyFromUtf8("simple-begin"))
  14.        .setEndKeyOpen(ByteString.copyFromUtf8("simple-end")))
  15.    .addRowRanges(
  16.      RowRange.newBuilder()
  17.        .setStartKeyClosed(ByteString.copyFromUtf8("byte-begin"))
  18.        .setEndKeyOpen(ByteString.copyFromUtf8("byte-end")))
  19.    .addRowRanges(
  20.      RowRange.newBuilder()
  21.        .setStartKeyClosed(ByteString.copyFromUtf8("range-begin"))
  22.        .setEndKeyOpen(ByteString.copyFromUtf8("range-end")));
  23.  ReadRowsRequest actualProto = query.toProto(requestContext);
  24.  assertThat(actualProto).isEqualTo(expectedProto.build());
  25. }

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

  1. @Test
  2. public void testFromProto() {
  3.  ReadRowsRequest request =
  4.    ReadRowsRequest.newBuilder()
  5.      .setTableName(NameUtil.formatTableName(PROJECT_ID, INSTANCE_ID, TABLE_ID))
  6.      .setAppProfileId(APP_PROFILE_ID)
  7.      .setFilter(RowFilter.newBuilder().setRowKeyRegexFilter(ByteString.copyFromUtf8(".*")))
  8.      .setRows(
  9.        RowSet.newBuilder()
  10.          .addRowKeys(ByteString.copyFromUtf8("row-key"))
  11.          .addRowRanges(
  12.            RowRange.newBuilder()
  13.              .setStartKeyClosed(ByteString.copyFromUtf8("j"))
  14.              .setEndKeyClosed(ByteString.copyFromUtf8("z"))))
  15.      .build();
  16.  Query query = Query.fromProto(request);
  17.  assertThat(query.toProto(requestContext)).isEqualTo(request);
  18. }

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

  1. assertThat(subQueries.get(0).toProto(requestContext))
  2.   .isEqualTo(
  3.     ReadRowsRequest.newBuilder()
  4.               .setEndKeyClosed(ByteString.copyFromUtf8("j"))))
  5.       .build());
  6. assertThat(subQueries.get(1).toProto(requestContext))
  7.   .isEqualTo(
  8.     ReadRowsRequest.newBuilder()

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

  1. assertThat(subQueries.get(0).toProto(requestContext))
  2.   .isEqualTo(
  3.     ReadRowsRequest.newBuilder()
  4.               .setEndKeyClosed(ByteString.copyFromUtf8("j"))))
  5.       .build());
  6. assertThat(subQueries.get(1).toProto(requestContext))
  7.   .isEqualTo(
  8.     ReadRowsRequest.newBuilder()

代码示例来源：origin: com.google.cloud/google-cloud-bigtable

  1. @Override
  2. public void call(Query request, ResponseObserver<RowT> responseObserver, ApiCallContext context) {
  3.  ReadRowsRequest innerRequest = request.toProto(requestContext);
  4.  inner.call(innerRequest, responseObserver, context);
  5. }

代码示例来源：origin: GoogleCloudPlatform/cloud-bigtable-client

  1. /** {@inheritDoc} */
  2. @Override
  3. public List<FlatRow> readFlatRowsList(Query request) {
  4.  return delegate.readFlatRowsList(request.toProto(requestContext));
  5. }

代码示例来源：origin: GoogleCloudPlatform/cloud-bigtable-client

  1. /** {@inheritDoc} */
  2. @Override
  3. public ResultScanner<FlatRow> readFlatRows(Query request) {
  4.  return delegate.readFlatRows(request.toProto(requestContext));
  5. }

代码示例来源：origin: GoogleCloudPlatform/cloud-bigtable-client

  1. /** {@inheritDoc} */
  2. @Override
  3. public ListenableFuture<List<FlatRow>> readFlatRowsAsync(Query request) {
  4.  return delegate.readFlatRowsAsync(request.toProto(requestContext));
  5. }

代码示例来源：origin: GoogleCloudPlatform/cloud-bigtable-client

  1. /**
  2.  * <p>adapt.</p>
  3.  *
  4.  * @param scan a {@link Scan} object.
  5.  * @return a {@link ReadRowsRequest} object.
  6.  */
  7. public ReadRowsRequest adapt(Scan scan) {
  8.  ReadHooks readHooks = new DefaultReadHooks();
  9.  Query query = Query.create(bigtableTableName.getTableId());
  10.  Adapters.SCAN_ADAPTER.adapt(scan, readHooks, query);
  11.  readHooks.applyPreSendHook(query);
  12.  return query.toProto(requestContext);
  13. }

代码示例来源：origin: GoogleCloudPlatform/cloud-bigtable-client

  1. /**
  2.  * <p>adapt.</p>
  3.  *
  4.  * @param get a {@link Get} object.
  5.  * @return a {@link ReadRowsRequest} object.
  6.  */
  7. public ReadRowsRequest adapt(Get get) {
  8.  ReadHooks readHooks = new DefaultReadHooks();
  9.  Query query = Query.create(bigtableTableName.getTableId());
  10.  Adapters.GET_ADAPTER.adapt(get, readHooks, query);
  11.  readHooks.applyPreSendHook(query);
  12.  return query.toProto(requestContext);
  13. }

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

query

相关文章

    查看更多

    热门标签

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

    最新文章

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