beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From github-...@apache.org
Subject [beam] tag nightly-master updated (ac57388 -> 2fd9875)
Date Tue, 10 Aug 2021 03:21:24 GMT
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 ac57388  (commit)
      to 2fd9875  (commit)
    from ac57388  Merge pull request #15246 from [BEAM-12685] Allow managed thread count in
AvroIO
     add 1d4a9cc  Merge pull request #15298 from [BEAM-12729] Suppress Avro Runtime Exceptions
for Streaming
     add 7e8c030  Refactor _RemoveDuplicates to use counter state (#15242)
     add a647b23  [BEAM-12716] Update XLang Kafka taxi example to use BigQuery sink
     add 6b774be  add comment
     add 2fd9875  Merge pull request #15269 from ihji/BEAM-12716

No new revisions were added by this update.

Summary of changes:
 .../main/java/org/apache/beam/sdk/io/AvroIO.java   |  46 +++++++--
 .../beam/sdk/io/ReadAllViaFileBasedSource.java     |  41 +++++++-
 .../apache_beam/examples/kafkataxi/kafka_taxi.py   | 109 +++++++++++++++------
 sdks/python/apache_beam/io/fileio.py               |  20 ++--
 4 files changed, 165 insertions(+), 51 deletions(-)

Mime
View raw message