Skip to content

Commit

Permalink
feat: publish the Cloud Bigtable Change Streams (#1237)
Browse files Browse the repository at this point in the history
* feat: publish the Cloud Bigtable Change Streams

PiperOrigin-RevId: 508465928

Source-Link: googleapis/googleapis@3770af2

Source-Link: googleapis/googleapis-gen@0280f1f
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMDI4MGYxZjViOTkwZDkwMTNhMWM0YzU1NWRlZjI0MWEzMTI0MjM3NiJ9

* 🦉 Updates from OwlBot post-processor

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

---------

Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
  • Loading branch information
gcf-owl-bot[bot] and gcf-owl-bot[bot] committed Feb 10, 2023
1 parent 41d2fc0 commit 000a353
Show file tree
Hide file tree
Showing 16 changed files with 10,280 additions and 4,382 deletions.
356 changes: 301 additions & 55 deletions protos/google/bigtable/v2/bigtable.proto

Large diffs are not rendered by default.

31 changes: 28 additions & 3 deletions protos/google/bigtable/v2/data.proto
Original file line number Diff line number Diff line change
Expand Up @@ -486,9 +486,7 @@ message Mutation {
}

// A Mutation which deletes all cells from the containing row.
message DeleteFromRow {

}
message DeleteFromRow {}

// Which of the possible Mutation types to apply.
oneof mutation {
Expand Down Expand Up @@ -533,3 +531,30 @@ message ReadModifyWriteRule {
int64 increment_amount = 4;
}
}

// NOTE: This API is intended to be used by Apache Beam BigtableIO.
// A partition of a change stream.
message StreamPartition {
// The row range covered by this partition and is specified by
// [`start_key_closed`, `end_key_open`).
RowRange row_range = 1;
}

// NOTE: This API is intended to be used by Apache Beam BigtableIO.
// The information required to continue reading the data from multiple
// `StreamPartitions` from where a previous read left off.
message StreamContinuationTokens {
// List of continuation tokens.
repeated StreamContinuationToken tokens = 1;
}

// NOTE: This API is intended to be used by Apache Beam BigtableIO.
// The information required to continue reading the data from a
// `StreamPartition` from where a previous read left off.
message StreamContinuationToken {
// The partition that this token applies to.
StreamPartition partition = 1;

// An encoded position in the stream to restart reading from.
string token = 2;
}
1,743 changes: 1,555 additions & 188 deletions protos/protos.d.ts

Large diffs are not rendered by default.

11,501 changes: 7,405 additions & 4,096 deletions protos/protos.js

Large diffs are not rendered by default.

278 changes: 278 additions & 0 deletions protos/protos.json

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

8 changes: 4 additions & 4 deletions samples/generated/v2/bigtable.check_and_mutate_row.js
Original file line number Diff line number Diff line change
Expand Up @@ -33,9 +33,8 @@ function main(tableName, rowKey) {
* TODO(developer): Uncomment these variables before running the sample.
*/
/**
* Required. The unique name of the table to which the conditional mutation should be
* applied.
* Values are of the form
* Required. The unique name of the table to which the conditional mutation
* should be applied. Values are of the form
* `projects/<project>/instances/<instance>/tables/<table>`.
*/
// const tableName = 'abc123'
Expand All @@ -45,7 +44,8 @@ function main(tableName, rowKey) {
*/
// const appProfileId = 'abc123'
/**
* Required. The key of the row to which the conditional mutation should be applied.
* Required. The key of the row to which the conditional mutation should be
* applied.
*/
// const rowKey = 'Buffer.from('string')'
/**
Expand Down
Loading

0 comments on commit 000a353

Please sign in to comment.