Skip to content
This repository was archived by the owner on Nov 12, 2025. It is now read-only.

feat: add AppendRowsStream helper to append rows with a BigQueryWriteClient #284

Merged
tswast merged 48 commits into from
Sep 10, 2021
Merged

feat: add AppendRowsStream helper to append rows with a BigQueryWriteClient #284

Changes from 2 commits
Commits
Show all changes
48 commits
Select commit Hold shift + click to select a range
c34e0bf
WIP: write client sample
tswast Aug 9, 2021
c9d6338
add sample with nullable types
tswast Aug 11, 2021
dbe2a21
add schema for all supported types
tswast Aug 11, 2021
e5b7b3f
add complex types to code sample
tswast Aug 12, 2021
2d927b1
refactor sample so that it can be tested
tswast Aug 16, 2021
19b746e
make test assertions more thorough
tswast Aug 16, 2021
f6af466
Merge branch 'master' into b195450856-write-client
tswast Aug 16, 2021
483b0e3
fix lint error
tswast Aug 16, 2021
a74e7ea
Merge remote-tracking branch 'origin/b195450856-write-client' into b1…
tswast Aug 16, 2021
eba8539
remove done TODO
tswast Aug 16, 2021
40e2800
address reviewer comments
tswast Aug 17, 2021
49c3c58
fix tag mismatch
tswast Aug 17, 2021
6d30337
test on multiple regions
tswast Aug 17, 2021
cc969eb
Merge remote-tracking branch 'upstream/master' into b195450856-write-…
tswast Aug 19, 2021
bba6df4
correct comments about why offset exists
tswast Aug 19, 2021
dcc648d
upgrade g-c-b
tswast Aug 19, 2021
12a82a1
WIP: invert stream using BiDi class
tswast Aug 20, 2021
1beb0b9
WIP: attempt to use Future for send instead
tswast Aug 20, 2021
34e5cbd
WIP: use futures, populated by background consumer
tswast Aug 23, 2021
d2491b1
make sure stream is actually open before returning from open
tswast Aug 23, 2021
daf42a8
copy close implementation from pub/sub
tswast Aug 24, 2021
c40b51f
support extra metadata
tswast Aug 25, 2021
8bcc36c
Merge remote-tracking branch 'upstream/master' into b195450856-write-…
tswast Aug 26, 2021
350628d
process exceptions, add open timeout
tswast Aug 26, 2021
4086445
sort imports
tswast Aug 26, 2021
4c7f60e
WIP: unit tests
tswast Aug 26, 2021
f42d871
drain futures when stream closes
tswast Aug 27, 2021
39cd7af
update docs
tswast Aug 27, 2021
cc9a0fb
add callbacks to detect when a stream fails
tswast Aug 27, 2021
1d7f76a
add unit tests
tswast Aug 27, 2021
b054fce
Merge branch 'main' into b195450856-write-client-BiDi
tswast Aug 27, 2021
29e25ce
Merge branch 'main' into b195450856-write-client-BiDi
tswast Aug 31, 2021
faaee9e
add sleep to loop waiting for RPC to be active
tswast Aug 31, 2021
46dd60e
don't freeze if initial RPC fails
tswast Aug 31, 2021
4563e4b
Merge remote-tracking branch 'upstream/main' into b195450856-write-cl…
tswast Sep 3, 2021
22b7b0c
add needed initializations so done() functions
tswast Sep 3, 2021
e307c8f
fail fast when there is a problem with the initial request
tswast Sep 3, 2021
2b26b3d
don't inherit concurrent.futures
tswast Sep 3, 2021
0e91a6a
Merge remote-tracking branch 'upstream/main' into b195450856-write-cl…
tswast Sep 8, 2021
a3185e9
add unit test for open timeout
tswast Sep 8, 2021
61fa79f
🦉 Updates from OwlBot
gcf-owl-bot[bot] Sep 8, 2021
6fc1c75
add manual client to docs
tswast Sep 8, 2021
7bddd4f
Merge remote-tracking branch 'origin/b195450856-write-client-BiDi' in…
tswast Sep 8, 2021
0c5d08c
typo in sample comments
tswast Sep 9, 2021
dc33c88
force timeout and metadata to be kwargs
tswast Sep 9, 2021
9b229a3
unify interface for sending row data
tswast Sep 9, 2021
001a922
pull stream name from merged request
tswast Sep 9, 2021
68507d8
require newer proto-plus for copy_from method
tswast Sep 10, 2021
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

These merge commits were added into this branch cleanly.

There are no new changes to show.