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 7b30339 (commit)
to 37fd13e (commit)
from 7b30339 [BEAM-12548] Add EqualsList functionality to PAssert (#15110)
add 7cfd330 [BEAM-11994] Update ShortIdMap's maps to only use valid
keyable fields in the MonitoringInfo (urn and labels).
add e4d27c1 Merge pull request #14804 from
ajamato/bq_metrics_process_wide_short_ids
add 22ec4e6 Add MatchContinuously PTransform to Python SDK (#15106)
add f077ba5 [BEAM-10955] Fix Flink Java Runner test flake: Could not find
Flink job (#15107)
add ee236d6 Add support for BigQuery data types aliases to
BigQueryAvroUtils
add 1837ea5 Merge pull request #15060 from [BEAM-10176] Support STRUCT,
FLOAT64, INT64 BigQuery types
add 0715b66 [BEAM-12548] Add examples of Equals and EqualsList to
equals_test.go (#15112)
add d6088d3 [BEAM-12076] Adds a Kafka external read transform for reading
with metadata (#15028)
add fe8d522 Update _index.md
add 360a1e5 Merge pull request #15047 from YuqiHuai/patch-1
add 999a77e [BEAM-12422] Remove all optional logging libraries as Netty
attempts to detect a compatible logger internally
add 37fd13e [BEAM-12422] Drop other optional logger libraries since Netty
can detect which logger is available automatically
No new revisions were added by this update.
Summary of changes:
.../apache/beam/gradle/GrpcVendoring_1_36_0.groovy | 5 -
.../beam/runners/core/metrics/ShortIdMap.java | 3 +
.../beam/runners/core/metrics/ShortIdMapTest.java | 133 ++++++++++++
.../beam/runners/flink/FlinkSavepointTest.java | 4 +-
sdks/go/pkg/beam/io/xlang/kafkaio/kafka.go | 2 +-
sdks/go/pkg/beam/testing/passert/equals_test.go | 67 ++++++
.../sdk/expansion/ExternalTransformRegistrar.java | 2 +-
.../sdk/io/gcp/bigquery/BigQueryAvroUtils.java | 7 +
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 227 ++++++++++++++++++---
.../beam/sdk/io/kafka/KafkaIOExternalTest.java | 149 ++++++++++++--
.../apache_beam/examples/kafkataxi/kafka_taxi.py | 36 +++-
sdks/python/apache_beam/io/fileio.py | 74 +++++++
sdks/python/apache_beam/io/fileio_test.py | 66 ++++++
sdks/python/apache_beam/io/kafka.py | 12 +-
website/www/site/content/en/contribute/_index.md | 2 +-
15 files changed, 729 insertions(+), 60 deletions(-)
create mode 100644
runners/core-java/src/test/java/org/apache/beam/runners/core/metrics/ShortIdMapTest.java
