You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2020/10/18 02:45:36 UTC
[beam] tag nightly-master updated (3591151 -> 7c357e4)
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 3591151 (commit)
to 7c357e4 (commit)
from 3591151 [BEAM-10114] Upgrade version of pubsublite to 0.4.1. (#12957)
add 8b9dc0f Merge pull request #13055 from [BEAM-11006] BigQuery failsafe function
add 488c10c Merge pull request #12864: [BEAM-10650] Windmill implementation for TimestampOrderedState
add 295f2a6 Updates Pub/Sub runner API transformation to preserve None values
add 7c357e4 Merge pull request #13135: [BEAM-10861] Updates Pub/Sub runner API transformation to preserve None values
No new revisions were added by this update.
Summary of changes:
.../beam/runners/dataflow/DataflowRunner.java | 7 -
.../dataflow/worker/WindmillStateInternals.java | 588 +++++++++++++++++++--
.../dataflow/worker/WindmillStateReader.java | 397 +++++++++-----
.../worker/WindmillStateInternalsTest.java | 346 ++++++++++++
.../dataflow/worker/WindmillStateReaderTest.java | 262 +++++++++
.../worker/windmill/src/main/proto/windmill.proto | 10 +-
...indow.java => FailsafeValueInSingleWindow.java} | 65 ++-
...a => FailsafeValueInSingleWindowCoderTest.java} | 23 +-
.../org/apache/beam/sdk/transforms/ParDoTest.java | 39 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 69 +--
.../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 3 +-
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 9 +-
.../beam/sdk/io/gcp/bigquery/ErrorContainer.java | 11 +-
.../beam/sdk/io/gcp/bigquery/RowWriterFactory.java | 18 +-
.../beam/sdk/io/gcp/bigquery/StreamingInserts.java | 17 +-
.../beam/sdk/io/gcp/bigquery/StreamingWriteFn.java | 18 +-
.../sdk/io/gcp/bigquery/StreamingWriteTables.java | 49 +-
.../sdk/io/gcp/testing/FakeDatasetService.java | 10 +-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 3 +-
.../io/gcp/bigquery/BigQueryServicesImplTest.java | 42 +-
.../beam/sdk/io/gcp/bigquery/BigQueryUtilTest.java | 9 +-
sdks/python/apache_beam/io/gcp/pubsub_test.py | 55 ++
sdks/python/apache_beam/io/iobase.py | 14 +-
23 files changed, 1763 insertions(+), 301 deletions(-)
copy sdks/java/core/src/main/java/org/apache/beam/sdk/values/{ValueInSingleWindow.java => FailsafeValueInSingleWindow.java} (58%)
copy sdks/java/core/src/test/java/org/apache/beam/sdk/testing/{ValueInSingleWindowCoderTest.java => FailsafeValueInSingleWindowCoderTest.java} (69%)