This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from 9e929bd (commit)
to e76b4db (commit)
from 9e929bd Merge pull request #15467: [BEAM-12851] Map output table names
add e12fc33 [BEAM-9008] adds CassandraIO.readAll
add b6c62ca Merge pull request #10546: [BEAM-9008] Add CassandraIO
readAll method
add 5a40505 [BEAM-12153] implement GroupByKey with CombinePerKey with
Concatenate CombineFn
add bccc5ea [BEAM-11023] Increase memory in SS Validates runner tests to
avoid OOM in beam coders
add fb0b6a8 [BEAM-12727] extract Concatenate CombineFn to runner-core
module to deduplicate it from many runners
add 9a72560 Merge pull request #15267 from
echauchot/BEAM-12153-spark-SS-runner-GBK-with-CPK
add 2876485 [BEAM-12708] Bump arrow-memory-netty
add b3014c4 [BEAM-12708] Bump arrow-memory-netty
add 9694f70 [BEAM-11205] Upgrading the Libraries BOM to v22
add 8367b43 [BEAM-11205] Upgrading the Google Cloud Libraries BOM to v22
add a89b12a Add display data for JdbcIO.write (#15460)
add e76b4db Merge pull request #15480: [BEAM-12356] Make sure
DatasetService is always closed
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 38 +-
.../org/apache/beam/runners/core/Concatenate.java | 74 +++
.../runners/flink/CreateStreamingFlinkView.java | 50 +-
.../FlinkBatchPortablePipelineTranslator.java | 53 +-
.../flink/FlinkBatchTransformTranslators.java | 52 +-
.../SamzaPublishViewTransformOverride.java | 43 +-
runners/spark/spark_runner.gradle | 2 +-
.../batch/GroupByKeyTranslatorBatch.java | 100 ++--
.../container/license_scripts/dep_urls_java.yaml | 4 +-
.../apache/beam/sdk/io/cassandra/CassandraIO.java | 540 ++++++---------------
.../beam/sdk/io/cassandra/ConnectionManager.java | 83 ++++
.../beam/sdk/io/cassandra/DefaultObjectMapper.java | 2 +-
.../io/cassandra/DefaultObjectMapperFactory.java | 2 +-
.../org/apache/beam/sdk/io/cassandra/ReadFn.java | 120 +++++
.../apache/beam/sdk/io/cassandra/RingRange.java | 46 +-
.../beam/sdk/io/cassandra/SplitGenerator.java | 16 +-
.../beam/sdk/io/cassandra/CassandraIOTest.java | 313 ++++++------
sdks/java/io/google-cloud-platform/build.gradle | 2 +-
.../sdk/io/gcp/bigquery/BatchedStreamingWrite.java | 93 ++--
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 129 ++---
.../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 11 +
21 files changed, 856 insertions(+), 917 deletions(-)
create mode 100644
runners/core-java/src/main/java/org/apache/beam/runners/core/Concatenate.java
create mode 100644
sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/ConnectionManager.java
create mode 100644
sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/ReadFn.java
