Skip to content
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.

Sign up for GitHub

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

Read API Source v2 #25392

Merged
merged 34 commits into from
Feb 22, 2023
Merged

Read API Source v2 #25392

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
34 commits
Select commit Hold shift + click to select a range
3ec1d08
ReadAPI Source v2
vachan-shetty Dec 5, 2022
0a2fc4f
Renamed the Source V2. Also added tests for the same.
vachan-shetty Jan 10, 2023
fc55a4f
v2 using OffsetBasedSource and OffsetBasedReader
vachan-shetty Feb 2, 2023
0b09d51
Updating tests to have more sensible mock values.
vachan-shetty Feb 3, 2023
409afac
Updated BqOption flag.
vachan-shetty Feb 3, 2023
ca02997
Simplifying `fractionConsumed` calculation.
vachan-shetty Feb 7, 2023
a6e2d73
Better variable names.
vachan-shetty Feb 7, 2023
f4677fa
Minor refactoring.
vachan-shetty Feb 7, 2023
139e317
Added a synchronized block in readNextRecord(). Also added comments t…
vachan-shetty Feb 8, 2023
7e1f974
Removed unnecessary synchronized block, added Javadoc and improved un…
vachan-shetty Feb 10, 2023
cf2cc08
Consolidated code paths in `BigQueryIO` for Bundled and regular ReadA…
vachan-shetty Feb 10, 2023
54e80ae
Lint fixes.
vachan-shetty Feb 13, 2023
dac8cfe
Minor Javadoc fix.
vachan-shetty Feb 13, 2023
d902326
Fix StreamBundle creation logic and some minor code comment updates.
vachan-shetty Feb 16, 2023
b45bdd7
Updated logging.
vachan-shetty Feb 16, 2023
323a080
Lint fixes.
vachan-shetty Feb 16, 2023
73c6528
ReadAPI Source v2
vachan-shetty Dec 5, 2022
fb24fbf
Renamed the Source V2. Also added tests for the same.
vachan-shetty Jan 10, 2023
65fea1a
v2 using OffsetBasedSource and OffsetBasedReader
vachan-shetty Feb 2, 2023
d71c304
Updating tests to have more sensible mock values.
vachan-shetty Feb 3, 2023
a87b56b
Updated BqOption flag.
vachan-shetty Feb 3, 2023
572467c
Simplifying `fractionConsumed` calculation.
vachan-shetty Feb 7, 2023
9778b35
Better variable names.
vachan-shetty Feb 7, 2023
e780266
Minor refactoring.
vachan-shetty Feb 7, 2023
03ca8d6
Added a synchronized block in readNextRecord(). Also added comments t…
vachan-shetty Feb 8, 2023
b337c57
Removed unnecessary synchronized block, added Javadoc and improved un…
vachan-shetty Feb 10, 2023
e02665f
Consolidated code paths in `BigQueryIO` for Bundled and regular ReadA…
vachan-shetty Feb 10, 2023
d248d66
Lint fixes.
vachan-shetty Feb 13, 2023
1432cbc
Minor Javadoc fix.
vachan-shetty Feb 13, 2023
3adc815
Fix StreamBundle creation logic and some minor code comment updates.
vachan-shetty Feb 16, 2023
5eb1aa4
Updated logging.
vachan-shetty Feb 16, 2023
d1a6d43
Lint fixes.
vachan-shetty Feb 16, 2023
0dd2aa6
Merge branch 'master' of https://github.com/vachan-shetty/beam into r…
vachan-shetty Feb 22, 2023
d536f42
Merge branch 'readapi-v2' of https://github.com/vachan-shetty/beam in…
vachan-shetty Feb 22, 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
Loading