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 b401d23 (commit)
to 8a78fa0 (commit)
from b401d23 Merge pull request #15115: [BEAM-12515] Revert "[BEAM-12119]
[BEAM-12122] Add integer and string `_id` keys support to Python IO MongoDB"
add 48d0d6c [BEAM-12583] Fix HarnessMonitoringInfoInstructionHandler to
us the short ID map properly
add 834ff89 Merge pull request #15139: [BEAM-12583] Fix
HarnessMonitoringInfoInstructionHandler to use the ShortIdMap properly
add 312df3e [BEAM-12511] Add ability to use JdbcIO.Write.withResults
without statement and preparedStatementSetter.
add 2a2107a Merge pull request #15052: [BEAM-12511]
JdbcIO.Write.withResult works without statement.
add 101baa8 Merge pull request #15135: [BEAM-10887] Timer clear Reapply
timer clear
add 880f9ee [BEAM-12547] Consume vendored gRPC 1.36.0 0.2 and fix test to
ensure epoll is tested.
add 4e50859 [BEAM-12547] Consume vendored gRPC 1.36.0 0.2 and fix test to
ensure epoll is tested.
add 085bc2b [BEAM-9547] Add implementations for some lesser-used pandas
operations (#15108)
add a32a75e Update Beam website to release 2.31.0.
add b1b735e Merge pull request #15068: Update Beam website to release
2.31.0.
add 66e319c Merge pull request #15054: Fix broken build.gradle release tag
add cfeac3b [BEAM-12513] Finish adding Go to BPG 4. Transforms (#15142)
add 1c51ad2 [BEAM-12548] Add unit tests for passert.go (#15141)
add 8a78fa0 [BEAM-9547] Identify remaining WontImplement operations
(#15095)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 16 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
release/src/main/scripts/set_version.sh | 4 +-
.../beam/runners/core/InMemoryTimerInternals.java | 3 +-
.../apache/beam/runners/core/SimpleDoFnRunner.java | 5 +
.../apache/beam/runners/core/TimerInternals.java | 20 +-
.../beam/runners/direct/DirectTimerInternals.java | 58 +++-
.../direct/StatefulParDoEvaluatorFactory.java | 56 ++-
.../beam/runners/direct/WatermarkManager.java | 89 +++--
.../wrappers/streaming/DoFnOperator.java | 4 +-
.../streaming/ExecutableStageDoFnOperator.java | 3 +-
.../dataflow/worker/WindmillTimerInternals.java | 12 +-
.../beam/runners/samza/runtime/KeyedInternals.java | 5 +-
.../samza/runtime/SamzaTimerInternalsFactory.java | 3 +-
.../spark/stateful/SparkTimerInternals.java | 2 +-
sdks/go/examples/snippets/04transforms.go | 141 ++++++++
sdks/go/examples/snippets/04transforms_test.go | 40 +++
sdks/go/pkg/beam/testing/passert/passert_test.go | 120 +++++++
.../main/java/org/apache/beam/sdk/state/Timer.java | 3 +
.../org/apache/beam/sdk/transforms/ParDoTest.java | 386 ++++++++++++++++++++-
sdks/java/fn-execution/build.gradle | 1 +
.../sdk/fn/channel/ManagedChannelFactoryTest.java | 8 +-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 11 +
.../HarnessMonitoringInfosInstructionHandler.java | 10 +-
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 16 +
...rnessMonitoringInfosInstructionHandlerTest.java | 2 -
.../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 255 +++++++-------
.../beam/sdk/io/jdbc/JdbcSchemaIOProvider.java | 1 -
.../org/apache/beam/sdk/io/jdbc/JdbcIOTest.java | 41 +++
sdks/python/apache_beam/dataframe/frames.py | 118 ++++++-
sdks/python/apache_beam/dataframe/frames_test.py | 122 ++++++-
.../apache_beam/dataframe/pandas_doctests_test.py | 12 +-
website/www/site/config.toml | 2 +-
website/www/site/content/en/blog/beam-2.31.0.md | 76 ++++
.../content/en/documentation/programming-guide.md | 204 ++++++++++-
.../www/site/content/en/get-started/downloads.md | 8 +
website/www/site/static/.htaccess | 2 +-
37 files changed, 1591 insertions(+), 270 deletions(-)
create mode 100644 sdks/go/pkg/beam/testing/passert/passert_test.go
create mode 100644 website/www/site/content/en/blog/beam-2.31.0.md
