This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from d41ae47 [BEAM-12976] Pipeline visitor to discover pushdown
opportunities. (#16176)
add a8bcfc2 [BEAM-13321] Pass TempLocation as pipeline option to Dataflow
Go for xlang.
add 6a552dc Merge pull request #16069: [BEAM-13321] Pass TempLocation as
pipeline option to Dataflow Go for XLang.
add ffb18c7 [BEAM-13015] Allow decoding a set of elements until we hit
the block boundary. (#16220)
add 124a8c2 [BEAM-13159] Add Redis Stream (XADD) Write Support (#15858)
add 0467235 [BEAM-13446]: fix incorrect tab symbol
add 395533e Merge pull request #16212 from [BEAM-13446] [Bugfix]
[Playground] fix incorrect tab symbol on the code editor
add 58932e8 [BEAM-13438][Playground] update precommit task for the backend
add 4471c1f Merge pull request #16199 from [BEAM-13438][Playground]
Update precommit task to run benchmarks
add bea8849 Merge pull request #15994: [BEAM-13263] Support
OnWindowExpiration in (non-portable) Flink runner
add 26caae2 Bump dataflow container version to beam-master-20211213
(#16213)
add ed276c9 Merge pull request #16198 from [BEAM-13437][Playground] Add
code_processing' benchmarks
add 836a89f Merge pull request #16195 from a[BEAM-13436][Playground] Add
precompiled_objects' benchmarksenchmarks-for-precompiled-objects
add a8162f2 [BEAM-13355] add Big Query parameter to enable users to
specify load_… (#16186)
add 267106d Removes the comment that seems no longer relevant.
add 96862c5 [BEAM-13434] Removes the comment that seems no longer
relevant. #16218
add 81ff949 Update a few dependencies that may depend on log4j
transitively.
add 1a74cc0 [BEAM-13434] Update PubSub lite dep to 1.4.5. #16223
add 20e79d1 Updated the base images to use debian:bullseye (#16221)
add f9b0d6d [BEAM-13434] Bump log4j to 2.16.0. (#16237)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 4 +-
playground/backend/build.gradle.kts | 30 +++
playground/backend/containers/go/Dockerfile | 2 +-
playground/backend/containers/go/build.gradle | 2 +-
playground/backend/containers/java/Dockerfile | 2 +-
playground/backend/containers/python/Dockerfile | 2 +-
playground/backend/containers/python/build.gradle | 2 +-
.../cloud_bucket/precompiled_objects_test.go | 37 +++-
.../code_processing/code_processing_test.go | 183 ++++++++++++++++++
.../code_client/grpc_code_client.dart | 15 +-
.../example_client/grpc_example_client.dart | 7 +-
.../lib/utils/replace_incorrect_symbols.dart | 8 +-
release/go-licenses/Dockerfile | 2 +-
.../org/apache/beam/runners/core/DoFnRunners.java | 2 -
.../apache/beam/runners/core/ProcessFnRunner.java | 5 +
.../runners/core/PushbackSideInputDoFnRunner.java | 3 +
.../core/SimplePushbackSideInputDoFnRunner.java | 5 +
.../beam/runners/core/StatefulDoFnRunner.java | 3 +-
runners/flink/flink_runner.gradle | 1 -
.../functions/FlinkStatefulDoFnFunction.java | 21 +++
.../wrappers/streaming/DoFnOperator.java | 10 +-
runners/google-cloud-dataflow-java/build.gradle | 2 +-
sdks/go/container/Dockerfile | 2 +-
.../pkg/beam/runners/dataflow/dataflowlib/job.go | 17 +-
sdks/java/container/Dockerfile | 2 +-
.../org/apache/beam/sdk/transforms/ParDoTest.java | 95 +++++++---
.../org/apache/beam/sdk/fn/stream/DataStreams.java | 29 ++-
.../apache/beam/sdk/fn/stream/DataStreamsTest.java | 84 +++++++--
.../elasticsearch-tests-5/build.gradle | 2 +-
.../elasticsearch-tests-6/build.gradle | 2 +-
.../elasticsearch-tests-7/build.gradle | 4 +-
.../elasticsearch-tests-common/build.gradle | 2 +-
sdks/java/io/hcatalog/build.gradle | 5 +-
sdks/java/io/redis/build.gradle | 2 +-
.../java/org/apache/beam/sdk/io/redis/RedisIO.java | 204 +++++++++++++++++++++
.../org/apache/beam/sdk/io/redis/RedisIOTest.java | 79 ++++++++
sdks/python/apache_beam/io/gcp/bigquery.py | 10 +-
.../apache_beam/io/gcp/bigquery_file_loads.py | 39 ++--
.../apache_beam/io/gcp/bigquery_file_loads_test.py | 84 +++++++++
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 9 +-
.../apache_beam/io/gcp/bigquery_tools_test.py | 12 ++
.../apache_beam/runners/dataflow/internal/names.py | 4 +-
sdks/python/container/Dockerfile | 2 +-
44 files changed, 932 insertions(+), 106 deletions(-)
copy learning/katas/java/Core Transforms/DoFn Additional Parameters/DoFn
Additional
Parameters/test/org/apache/beam/learning/katas/coretransforms/dofnadditionalparams/TaskTest.java
=> playground/frontend/lib/utils/replace_incorrect_symbols.dart (72%)
