This is an automated email from the ASF dual-hosted git repository.
stankiewicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 268ae1acf5e [IcebergIO] Support hash distribution mode when writing
rows (#38061)
add 26ef659b84a bump opentelemetry version.
add df9a0424eac add libraries
add 5223c232606 Model changes to allow OpenTelemetry context propagation
spotless. rename fields, cleanup groovy spotless rename method, fix constructor
invocation.
new 674873d7a87 Merge pull request #36962 from stankiewicz/model
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 8 +-
...TimeBoundedSplittableProcessElementInvoker.java | 6 +-
.../core/SplittableParDoViaKeyedWorkItems.java | 3 +-
runners/google-cloud-dataflow-java/build.gradle | 1 +
.../beam/runners/dataflow/BatchViewOverrides.java | 6 +
.../google-cloud-dataflow-java/worker/build.gradle | 1 +
.../dataflow/worker/UngroupedWindmillReader.java | 14 +-
.../dataflow/worker/WindmillKeyedWorkItem.java | 2 +-
.../dataflow/worker/util/ValueInEmptyWindows.java | 6 +
runners/spark/spark_runner.gradle | 1 +
.../apache/beam/runners/spark/util/TimerUtils.java | 6 +
.../container/license_scripts/dep_urls_java.yaml | 8 +-
sdks/java/core/build.gradle | 1 +
.../org/apache/beam/sdk/transforms/DoFnTester.java | 11 +-
.../java/org/apache/beam/sdk/transforms/Reify.java | 3 +-
.../sdk/values/OpenTelemetryContextPropagator.java | 71 ++++++++
.../org/apache/beam/sdk/values/OutputBuilder.java | 3 +
.../beam/sdk/values/ValueInSingleWindow.java | 37 +++-
.../org/apache/beam/sdk/values/WindowedValue.java | 4 +
.../org/apache/beam/sdk/values/WindowedValues.java | 196 +++++++++++++++------
.../apache/beam/sdk/util/WindowedValueTest.java | 21 ++-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 3 +-
.../apache/beam/sdk/io/gcp/GcpApiSurfaceTest.java | 1 +
23 files changed, 338 insertions(+), 75 deletions(-)
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/values/OpenTelemetryContextPropagator.java
