Skip to content
This repository was archived by the owner on Mar 26, 2026. It is now read-only.

feat: publish the Cloud Bigtable Change Streams #1237

Merged
danieljbruce merged 2 commits into from
Feb 10, 2023
Merged

feat: publish the Cloud Bigtable Change Streams #1237

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
fa288fc
feat: publish the Cloud Bigtable Change Streams
gcf-owl-bot[bot] Feb 9, 2023
e526ea2
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] Feb 9, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
356 changes: 301 additions & 55 deletions protos/google/bigtable/v2/bigtable.proto
View file
Open in desktop

Large diffs are not rendered by default.

31 changes: 28 additions & 3 deletions protos/google/bigtable/v2/data.proto
View file
Open in desktop
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
View file
Open in desktop

Large diffs are not rendered by default.

11,501 changes: 7,405 additions & 4,096 deletions protos/protos.js
View file
Open in desktop

Large diffs are not rendered by default.

278 changes: 278 additions & 0 deletions protos/protos.json
View file
Open in desktop

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
View file
Open in desktop
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