-
Notifications
You must be signed in to change notification settings - Fork 1.1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add integration tests for snapshot read and resuming. #5242
Conversation
The change adds the following integration tests: * Resuming by row offset when calling ReadRows. * Reading rows at different snapshots in time.
cc: @JesseLovelace |
Applying feedback from @sduskis.
Codecov Report
@@ Coverage Diff @@
## master #5242 +/- ##
=========================================
Coverage 50.48% 50.48%
Complexity 23875 23875
=========================================
Files 2258 2258
Lines 227482 227482
Branches 24978 24978
=========================================
Hits 114834 114834
Misses 104029 104029
Partials 8619 8619 Continue to review full report at Codecov.
|
...torage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/it/ITBigQueryStorageTest.java
Outdated
Show resolved
Hide resolved
...torage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/it/ITBigQueryStorageTest.java
Outdated
Show resolved
Hide resolved
@@ -104,6 +151,57 @@ public void testSimpleRead() { | |||
assertEquals(164_656, avroRowCount); | |||
} | |||
|
|||
@Test | |||
public void testSimpleReadAndResume() { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What is the end user use case for resume? Shouldn't this be handled transparently by the client?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@kmjung , it is handled transparently by the client. The goal of this test is to explicitly verify it.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Resuming by offset can also be used explicitly by clients in scenarios:
- The row progress per stream is stored in customers systems
- Customer pauses the stream reading for applying changes on their system.
- Customer resumes processing.
I thought it would be good to have an explicit tests for this functionality.
Applying feedback from @shollyman.
Kokoro - Test: Windows Java 8 failure is unrelated to changes (spanner flakes). |
The change adds the following integration tests:
@tswast or @shollyman, please review.
CC: @kmjung , @aryann