This is an automated email from the ASF dual-hosted git repository.
sivabalan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from bb42c4b96f0 [HUDI-7097] Fix instantiation of Hms Uri with HiveSync
tool (#10099)
add a7fd27ccfc7 [HUDI-7086] Scaling gcs event source (#10073)
No new revisions were added by this update.
Summary of changes:
.../hudi/utilities/config/CloudSourceConfig.java | 20 +++-
.../hudi/utilities/sources/GcsEventsSource.java | 7 +-
.../sources/helpers/gcs/PubsubMessagesFetcher.java | 102 ++++++++++++-------
.../sources/helpers/gcs/PubsubQueueClient.java | 80 +++++++++++++++
.../helpers/gcs/TestPubsubMessagesFetcher.java | 110 +++++++++++++++++++++
5 files changed, 279 insertions(+), 40 deletions(-)
create mode 100644
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/gcs/PubsubQueueClient.java
create mode 100644
hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/gcs/TestPubsubMessagesFetcher.java
