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 195cc593590 Update python-pipeline-dependencies.md (#37561)
add 7df489cb7c6 add datadog it support (#37517)
add 91d3b6b1d39 move enum to top level class
add 4a2afe85f9f move enum to sdk core changed boolean causedByDrain in
WindowedValue interface to enum. spotless
add aaecfa8f545 Merge pull request #37549: Move CausedByDrain to top
level, move types
add 0228126c1b7 Update reviewers (#37572)
add d6390b86f0f Download performance looks to static while building
website (#37559)
No new revisions were added by this update.
Summary of changes:
.github/REVIEWERS.yml | 1 -
.../workflows/beam_PreCommit_Website_Stage_GCS.yml | 12 +-
.github/workflows/beam_Publish_Website.yml | 8 +-
it/{mongodb => datadog}/build.gradle | 40 ++-
.../beam/it/datadog/DatadogClientFactory.java} | 28 +-
.../apache/beam/it/datadog/DatadogLogEntry.java | 31 +-
.../beam/it/datadog/DatadogResourceManager.java | 335 +++++++++++++++++++++
.../datadog/DatadogResourceManagerException.java} | 10 +-
.../it/datadog/DatadogResourceManagerUtils.java | 70 +++++
.../datadog/conditions/DatadogLogEntriesCheck.java | 91 ++++++
.../beam/it/datadog/conditions}/package-info.java | 4 +-
.../beam/it/datadog/matchers/DatadogAsserts.java} | 36 ++-
.../beam/it/datadog/matchers}/package-info.java | 8 +-
.../org/apache/beam/it/datadog}/package-info.java | 8 +-
.../beam/it/datadog/DatadogResourceManagerIT.java | 77 +++++
.../it/datadog/DatadogResourceManagerTest.java | 188 ++++++++++++
.../datadog/DatadogResourceManagerUtilsTest.java | 67 +++++
.../beam/runners/core/ReduceFnContextFactory.java | 10 +-
.../core/SplittableParDoViaKeyedWorkItems.java | 3 +-
.../apache/beam/runners/core/TimerInternals.java | 12 +-
.../runners/core/InMemoryTimerInternalsTest.java | 37 +--
.../beam/runners/core/KeyedWorkItemCoderTest.java | 3 +-
.../apache/beam/runners/core/ReduceFnTester.java | 5 +-
.../beam/runners/core/SimpleDoFnRunnerTest.java | 3 +-
.../SimplePushbackSideInputDoFnRunnerTest.java | 5 +-
.../beam/runners/core/TimerInternalsTest.java | 59 +---
.../core/triggers/TriggerStateMachineTester.java | 10 +-
.../runners/direct/DirectTimerInternalsTest.java | 13 +-
...cycleManagerRemovingTransformEvaluatorTest.java | 3 +-
.../beam/runners/direct/EvaluationContextTest.java | 3 +-
.../beam/runners/direct/WatermarkManagerTest.java | 85 ++----
.../beam/runners/dataflow/BatchViewOverrides.java | 5 +-
.../dataflow/worker/UngroupedWindmillReader.java | 7 +-
.../dataflow/worker/WindmillKeyedWorkItem.java | 7 +-
.../dataflow/worker/WindmillTimerInternals.java | 5 +-
.../dataflow/worker/util/ValueInEmptyWindows.java | 5 +-
.../worker/StreamingGroupAlsoByWindowFnsTest.java | 3 +-
...eamingKeyedWorkItemSideInputDoFnRunnerTest.java | 3 +-
.../worker/StreamingModeExecutionContextTest.java | 3 +-
.../worker/StreamingSideInputFetcherTest.java | 3 +-
.../dataflow/worker/UserParDoFnFactoryTest.java | 7 +-
.../dataflow/worker/WindmillKeyedWorkItemTest.java | 9 +-
.../windmill/state/WindmillTagEncodingV1Test.java | 15 +-
.../windmill/state/WindmillTagEncodingV2Test.java | 3 +-
.../samza/runtime/ClassicBundleManager.java | 3 +-
.../samza/runtime/PortableBundleManager.java | 3 +-
.../runners/samza/runtime/KeyedTimerDataTest.java | 3 +-
.../runtime/SamzaTimerInternalsFactoryTest.java | 25 +-
.../apache/beam/runners/spark/util/TimerUtils.java | 5 +-
.../org/apache/beam/sdk/values/CausedByDrain.java | 6 +-
.../org/apache/beam/sdk/values/OutputBuilder.java | 2 +-
.../org/apache/beam/sdk/values/WindowedValue.java | 2 +-
.../org/apache/beam/sdk/values/WindowedValues.java | 58 ++--
.../apache/beam/sdk/util/WindowedValueTest.java | 5 +-
settings.gradle.kts | 1 +
website/Dockerfile | 17 ++
website/build.gradle | 51 ++++
website/www/site/data/performance.yaml | 1 +
.../site/layouts/shortcodes/performance_looks.html | 21 +-
59 files changed, 1210 insertions(+), 333 deletions(-)
copy it/{mongodb => datadog}/build.gradle (53%)
copy
it/{splunk/src/main/java/org/apache/beam/it/splunk/SplunkClientFactory.java =>
datadog/src/main/java/org/apache/beam/it/datadog/DatadogClientFactory.java}
(60%)
copy
sdks/java/io/datadog/src/main/java/org/apache/beam/sdk/io/datadog/DatadogEvent.java
=> it/datadog/src/main/java/org/apache/beam/it/datadog/DatadogLogEntry.java
(78%)
create mode 100644
it/datadog/src/main/java/org/apache/beam/it/datadog/DatadogResourceManager.java
copy
it/{mongodb/src/main/java/org/apache/beam/it/mongodb/MongoDBResourceManagerException.java
=>
datadog/src/main/java/org/apache/beam/it/datadog/DatadogResourceManagerException.java}
(75%)
create mode 100644
it/datadog/src/main/java/org/apache/beam/it/datadog/DatadogResourceManagerUtils.java
create mode 100644
it/datadog/src/main/java/org/apache/beam/it/datadog/conditions/DatadogLogEntriesCheck.java
copy it/{google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub =>
datadog/src/main/java/org/apache/beam/it/datadog/conditions}/package-info.java
(88%)
copy
it/{mongodb/src/main/java/org/apache/beam/it/mongodb/matchers/MongoDBAsserts.java
=>
datadog/src/main/java/org/apache/beam/it/datadog/matchers/DatadogAsserts.java}
(56%)
copy
{examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization
=>
it/datadog/src/main/java/org/apache/beam/it/datadog/matchers}/package-info.java
(70%)
copy
{examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization
=> it/datadog/src/main/java/org/apache/beam/it/datadog}/package-info.java (70%)
create mode 100644
it/datadog/src/test/java/org/apache/beam/it/datadog/DatadogResourceManagerIT.java
create mode 100644
it/datadog/src/test/java/org/apache/beam/it/datadog/DatadogResourceManagerTest.java
create mode 100644
it/datadog/src/test/java/org/apache/beam/it/datadog/DatadogResourceManagerUtilsTest.java
copy learning/tour-of-beam/frontend/lib/constants/storage_keys.dart =>
sdks/java/core/src/main/java/org/apache/beam/sdk/values/CausedByDrain.java (89%)
