This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/go_modules/sdks/google.golang.org/api-0.226.0
in repository https://gitbox.apache.org/repos/asf/beam.git
omit 9f3ce23d8e4 Bump google.golang.org/api from 0.221.0 to 0.226.0 in /sdks
add df5dd4e0b87 Update roadmap page 28342 (#34330)
add e71fdce4d69 [KafkaIO] Fix average record size data race and backlog
estimation (#34165)
add f8a6783add0 Expose add-modules JVM option in SDKHarnessOptions (#34289)
add 99eee0f1e68 [AnomalyDetection] Refactor and improve Specifiable
(#34310)
add 9340965ce33 Bump golang.org/x/oauth2 from 0.26.0 to 0.28.0 in /sdks
(#34190)
add 42b15a1aa58 Support directory separator for Python local filesystem
(#34318)
add 5a8964c0d34 Bump github.com/nats-io/nats.go from 1.39.0 to 1.39.1 in
/sdks (#34029)
add e8d05a6f6bf Make yaml provider an abstract class.
add 5128a608fbc Add support for python package dependencies on UDFs.
add 99b340f57a0 Add dependency support for delegating providers.
add e4030417033 Allow dependency declarations for java.
add 18f237eeb18 Make yapf, lint, and mypy happy, fix test.
add e0b9d03038a Merge pull request #34073 Allow declaration of external
dependencies for YAML UDFs.
add 38281489a03 [AnomalyDetection] Support offline detectors (#34311)
add be19d132c56 add option to disable metrics (#34303)
add 0a9754353fb initial schema transform provider implementation for SQS
read functionality.
add 8ec917c15cd fixing checkstyle errors.
add ed3e63c9939 removing region configuration since its not needed
add b8337e4f667 adding package info for the new providers
add d0d652034f7 added tests to the provider
add 65887a08059 Merge pull request #34327: Enable xlang access for SQS
read functionality
add f15ce0272b5 [Dataflow Streaming] WindmillTimerInternals: Use a single
map to store timer data + liveness (#34292)
add 50b27874291 add equals hashCode to BoundedToUnboundedSourceAdapter
(#34057)
add a45b0dfc5d6 Remove cancelled tasks from ReadOperation queue when
shutting down (#34335)
add 77841f4494c [Prism] Refactor stageState to a behavior interface to
reduce branch combinatorics (#34132)
add 77c2dacd1c1 More precise binary operation inference. (#34305)
add b5358c30d42 Fix precommit flink container (#34250)
add 6147d44428a Aggregation option in Kinesis Writer Python sdk (#34323)
add 8b7b9893822 Add an experiment named enableLineageRollup which when
passed to Java SDK will make it report Lineage as BoundedTrie
add 70da92a1606 Allow boundedtrie emission outside of lineage usecase
add 927dfd31e41 Update Lineage query result to support BoundedTrie and
StringSet both
add d4a939e86fa Merge pull request #34312 Add enableLineageRollup
experiment for enabling Lineage as BoundedTrie in Java.
add 39a7bb4c088 update CHANGES with Read bugs/improvements (#34344)
add c1a45165cd1 Revert Skip BoundedTrie on Dataflow till service is have
BoundedTrie #33921
add 7adf9a2ab30 Do not runner UsesBoundedTrie test on Dataflow runner as
the test verify metric result
add 52a161f84a4 Merge pull request #34294 from rohitsinha54/unskip-btrie
add 596b18a69e7 [#31438] Add changes.md message for Trigger support in
Prism. (#34346)
add 27c40acd6d5 Bump cloud.google.com/go/storage from 1.50.0 to 1.51.0 in
/sdks (#34340)
add f25f81dbeb1 Bump serialize-javascript and mocha in /sdks/typescript
(#34012)
add ceb35359af2 Bump google.golang.org/api from 0.221.0 to 0.226.0 in /sdks
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (9f3ce23d8e4)
\
N -- N -- N
refs/heads/dependabot/go_modules/sdks/google.golang.org/api-0.226.0
(ceb35359af2)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
...m_PostCommit_Java_ValidatesRunner_Dataflow.json | 3 +-
.../workflows/beam_PreCommit_Flink_Container.yml | 33 +-
.../python_Combine_Flink_Batch_small.txt | 1 -
.../tools/stale_dataflow_prebuilt_image_cleaner.sh | 2 +-
CHANGES.md | 9 +-
build.gradle.kts | 1 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
runners/google-cloud-dataflow-java/build.gradle | 4 +-
.../dataflow/worker/BatchModeExecutionContext.java | 19 +-
.../worker/StreamingStepMetricsContainer.java | 6 +-
.../dataflow/worker/WindmillTimerInternals.java | 32 +-
.../worker/util/common/worker/ReadOperation.java | 12 +-
.../worker/StreamingStepMetricsContainerTest.java | 3 -
runners/prism/java/build.gradle | 4 +-
sdks/go.mod | 22 +-
sdks/go.sum | 52 +-
.../prism/internal/engine/elementmanager.go | 455 +++++----
sdks/java/container/boot.go | 8 +-
.../java/org/apache/beam/sdk/metrics/Lineage.java | 75 +-
.../java/org/apache/beam/sdk/metrics/Metrics.java | 21 +-
.../apache/beam/sdk/options/SdkHarnessOptions.java | 19 +-
.../UnboundedReadFromBoundedSource.java | 15 +
.../org/apache/beam/sdk/metrics/MetricsTest.java | 8 +
.../UnboundedReadFromBoundedSourceTest.java | 5 +-
.../io/aws2/kinesis/KinesisTransformRegistrar.java | 36 +-
.../aws2/sqs/providers/SqsReadConfiguration.java} | 44 +-
.../providers/SqsReadSchemaTransformProvider.java | 131 +++
.../sdk/io/aws2/sqs/providers}/package-info.java | 4 +-
.../SqsReadSchemaTransformProviderTest.java} | 65 +-
.../build.gradle => io/kafka/jmh/build.gradle.kts} | 19 +-
.../sdk/io/kafka/jmh/KafkaIOUtilsBenchmark.java | 235 +++++
.../beam/sdk/io/kafka/jmh}/package-info.java | 4 +-
.../beam/sdk/io/kafka/KafkaIOInitializer.java | 5 +-
.../org/apache/beam/sdk/io/kafka/KafkaIOUtils.java | 43 +-
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 20 +-
.../beam/sdk/io/kafka/ReadFromKafkaDoFn.java | 94 +-
.../io/external/xlang_kinesisio_it_test.py | 20 +
sdks/python/apache_beam/io/kinesis.py | 20 +
sdks/python/apache_beam/io/textio.py | 3 +
sdks/python/apache_beam/io/textio_test.py | 18 +
sdks/python/apache_beam/ml/anomaly/base.py | 4 +-
.../apache_beam/ml/anomaly/detectors/offline.py | 59 ++
sdks/python/apache_beam/ml/anomaly/specifiable.py | 175 ++--
.../apache_beam/ml/anomaly/specifiable_test.py | 54 +-
sdks/python/apache_beam/ml/anomaly/transforms.py | 98 +-
.../apache_beam/ml/anomaly/transforms_test.py | 197 ++++
.../python/apache_beam/options/pipeline_options.py | 14 +-
.../runners/portability/expansion_service_main.py | 2 +-
.../portability/fn_api_runner/worker_handlers.py | 1 +
sdks/python/apache_beam/typehints/opcodes.py | 40 +-
.../typehints/trivial_inference_test.py | 16 +
sdks/python/apache_beam/utils/subprocess_server.py | 35 +-
.../yaml/examples/testing/examples_test.py | 27 +
...rce_hints.yaml => map_to_fields_with_deps.yaml} | 39 +-
.../elementwise/map_to_fields_with_java_deps.yaml | 57 ++
.../apache_beam/yaml/yaml_enrichment_test.py | 3 +
sdks/python/apache_beam/yaml/yaml_mapping.py | 5 +-
sdks/python/apache_beam/yaml/yaml_provider.py | 99 +-
sdks/python/apache_beam/yaml/yaml_transform.py | 14 +
sdks/python/setup.py | 4 +-
sdks/typescript/package-lock.json | 1008 +++++++++++++-------
sdks/typescript/package.json | 2 +-
settings.gradle.kts | 1 +
website/www/site/content/en/roadmap/_index.md | 14 +-
website/www/site/content/en/roadmap/python-sdk.md | 6 +-
65 files changed, 2656 insertions(+), 890 deletions(-)
copy sdks/java/{core/src/main/java/org/apache/beam/sdk/schemas/io/Failure.java
=>
io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/providers/SqsReadConfiguration.java}
(54%)
create mode 100644
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/providers/SqsReadSchemaTransformProvider.java
copy
{examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/options
=>
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/providers}/package-info.java
(85%)
copy
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sqs/{SqsIOReadTest.java
=> providers/SqsReadSchemaTransformProviderTest.java} (68%)
copy sdks/java/{container/java17/build.gradle =>
io/kafka/jmh/build.gradle.kts} (64%)
create mode 100644
sdks/java/io/kafka/jmh/src/main/java/org/apache/beam/sdk/io/kafka/jmh/KafkaIOUtilsBenchmark.java
copy sdks/java/{core/jmh/src/main/java/org/apache/beam/sdk/jmh/io =>
io/kafka/jmh/src/main/java/org/apache/beam/sdk/io/kafka/jmh}/package-info.java
(91%)
create mode 100644 sdks/python/apache_beam/ml/anomaly/detectors/offline.py
copy
sdks/python/apache_beam/yaml/examples/transforms/elementwise/{map_to_fields_with_resource_hints.yaml
=> map_to_fields_with_deps.yaml} (60%)
create mode 100644
sdks/python/apache_beam/yaml/examples/transforms/elementwise/map_to_fields_with_java_deps.yaml
