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 4351c49 [BEAM-13001] collect DoFn metrics for Combine (#15911)
add e462607 [BEAM-8727] Bump software.amazon.awssdk to 2.17.77
add 986cffa Merge pull request #15935: [BEAM-8727] Bump
software.amazon.awssdk to 2.17.77
add 120a4ef [BEAM-4868] Bump com.amazonaws to 1.12.106
add 692227d Merge pull request #15932: [BEAM-4868] Bump com.amazonaws to
1.12.106
add 4c0479b [BEAM-13147] Fix nullability issues in aws (SDK v1 + v2) for
AwsModule (#15843)
add d4c5835 [BEAM-3293] Add encoding of map/multimap side inputs into
proto (#15960)
add be22467 [BEAM-13052] Implement ProtoPlusCoder and add it to the
default options (#15817)
add b655cbe [BEAM-13009] Bugfix: Prevent dataloss in DynamoDBIO write if
deduplication keys are not set (aws2)
add cf2a715 Merge pull request #15895: [BEAM-13009] Bugfix: Prevent
dataloss in DynamoDBIO write if deduplication keys are not set (aws SDK v2)
add 82443b6 [BEAM-13009] Bugfix: Prevent dataloss in DynamoDBIO write if
deduplication keys are not set (aws sdk v1)
add 61c9d1e Merge pull request #15898: [BEAM-13009] Bugfix: Prevent
dataloss in DynamoDBIO write if deduplication keys are not set (aws SDK v1)
add 28c3d1c [BEAM-13224][Playground] Add using context to local cache to
stop goroutine
add 93e5e61 Merge pull request #15959 from [BEAM-13224][Playground] Local
cache creates an forever used goroutine
add fc1c08e [BEAM-13193] Add elements field in ProcessBundleRequest and
ProcessBu… (#15917)
add cfeb0f0 [BEAM-3304] Refactor trigger API (#15952)
add a05ff52 [BEAM-3293] Add NewKeyedIterable function to SideInputAdapter
interface (#15966)
add fd00fc9 [BEAM-13223] Documents two new features of cross-language
transforms (#15941)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 2 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 4 +-
.../fn-execution/src/main/proto/beam_fn_api.proto | 18 ++
.../pipeline/src/main/proto/beam_runner_api.proto | 12 +
.../backend/internal/cache/local/local_cache.go | 23 +-
.../internal/cache/local/local_cache_test.go | 8 +-
sdks/go/pkg/beam/core/graph/window/strategy.go | 2 +-
.../pkg/beam/core/graph/window/trigger/trigger.go | 230 +++++++++-----
sdks/go/pkg/beam/core/runtime/exec/sideinput.go | 7 +-
sdks/go/pkg/beam/core/runtime/exec/unit_test.go | 4 +
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 92 +++---
sdks/go/pkg/beam/runners/direct/buffer.go | 4 +
sdks/go/pkg/beam/windowing.go | 2 +-
.../beam/sdk/io/aws/dynamodb/DynamoDBIO.java | 54 +++-
.../apache/beam/sdk/io/aws/options/AwsModule.java | 181 +++++------
.../sdk/io/aws/dynamodb/DynamoDBIOReadTest.java | 201 ++++++++++++
.../beam/sdk/io/aws/dynamodb/DynamoDBIOTest.java | 70 ++---
.../sdk/io/aws/dynamodb/DynamoDBIOWriteTest.java | 344 +++++++++++++++++++++
...iderMock.java => StaticAwsClientsProvider.java} | 37 ++-
.../beam/sdk/io/aws/options/AwsModuleTest.java | 32 +-
.../beam/sdk/io/aws2/dynamodb/DynamoDBIO.java | 52 ++--
.../apache/beam/sdk/io/aws2/options/AwsModule.java | 112 ++++---
.../sdk/io/aws2/dynamodb/DynamoDBIOReadTest.java | 199 ++++++++++++
.../beam/sdk/io/aws2/dynamodb/DynamoDBIOTest.java | 38 ++-
.../sdk/io/aws2/dynamodb/DynamoDBIOWriteTest.java | 343 ++++++++++++++++++++
...Mock.java => StaticDynamoDBClientProvider.java} | 34 +-
.../kinesis/DynamicCheckpointGeneratorTest.java | 18 +-
.../beam/sdk/io/kinesis/serde/AwsModule.java | 19 +-
sdks/python/apache_beam/coders/coder_impl.py | 14 +
sdks/python/apache_beam/coders/coders.py | 40 ++-
sdks/python/apache_beam/coders/coders_test.py | 41 +++
.../apache_beam/coders/coders_test_common.py | 4 +-
sdks/python/apache_beam/coders/typecoders.py | 4 +-
sdks/python/container/base_image_requirements.txt | 1 +
sdks/python/setup.py | 1 +
.../en/documentation/patterns/cross-language.md | 2 +
.../content/en/documentation/programming-guide.md | 146 +++++++++
37 files changed, 1979 insertions(+), 416 deletions(-)
create mode 100644
sdks/java/io/amazon-web-services/src/test/java/org/apache/beam/sdk/io/aws/dynamodb/DynamoDBIOReadTest.java
create mode 100644
sdks/java/io/amazon-web-services/src/test/java/org/apache/beam/sdk/io/aws/dynamodb/DynamoDBIOWriteTest.java
rename
sdks/java/io/amazon-web-services/src/test/java/org/apache/beam/sdk/io/aws/dynamodb/{AwsClientsProviderMock.java
=> StaticAwsClientsProvider.java} (54%)
create mode 100644
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/dynamodb/DynamoDBIOReadTest.java
create mode 100644
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/dynamodb/DynamoDBIOWriteTest.java
rename
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/dynamodb/{DynamoDbClientProviderMock.java
=> StaticDynamoDBClientProvider.java} (52%)
