You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2023/02/19 04:29:59 UTC
[beam] branch nightly-refs/heads/master updated (40838f76447 -> 977e53104f4)
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 40838f76447 Support Avro GenericRecord as a valid format for StorageWrite API on BigQueryIO (#24274)
add ee9244d6261 complete examples links fixed
add 20c8d3a2ba1 Merge pull request #25527: [CdapIO][SparkReceiverIO] Complete examples links in READMEs and CdapIO website page fixed
add 6de67443528 Stop use of self hosted runners for some workflows. (#25542)
add 29856ae9471 Run prbot updates on hosted runners (#25544)
add f358fcdc8c8 prism-fixstatic (#25546)
add 86920261ca7 Update Go SDK minimum Go version to 1.19 (#25545)
add 2b6291250f9 Replace more uses of `ClassLoadingStrategy.Default.INJECTION` (#23210)
add 907533220b8 Use WindowedValue.withValue on hot paths #21250 (#25519)
add de7eb2d83b0 Stop paying the iterator object creation tax in MultiplexingMetricTrackingFnDataReceiver (#25540)
add 977e53104f4 [prism] add windowing strategy (#25518)
No new revisions were added by this update.
Summary of changes:
.../actions/setup-self-hosted-action/action.yml | 8 +-
.github/workflows/build_playground_frontend.yml | 2 +-
.github/workflows/git_tag_released_version.yml | 2 +-
.github/workflows/go_tests.yml | 4 +-
.github/workflows/issue-tagger.yml | 2 +-
.github/workflows/label_prs.yml | 2 +-
.github/workflows/playground_deploy_backend.yml | 2 +-
.github/workflows/pr-bot-new-prs.yml | 2 +-
.github/workflows/pr-bot-pr-updates.yml | 2 +-
.github/workflows/pr-bot-prs-needing-attention.yml | 2 +-
.github/workflows/publish_github_release_notes.yml | 4 +-
.github/workflows/python_tests.yml | 2 +-
.github/workflows/reportGenerator.yml | 2 +-
.github/workflows/self-assign.yml | 2 +-
.github/workflows/stale.yml | 2 +-
.github/workflows/triaged-on-assign.yml | 2 +-
CHANGES.md | 1 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
dev-support/docker/Dockerfile | 2 +-
sdks/go.mod | 2 +-
.../beam/runners/prism/internal/engine/strategy.go | 39 +++-
.../prism/internal/engine/strategy_test.go} | 42 ++--
.../prism/internal/jobservices/metrics_test.go | 3 +-
.../apache/beam/sdk/coders/RowCoderGenerator.java | 7 +-
.../beam/sdk/schemas/utils/AvroByteBuddyUtils.java | 5 +-
.../beam/sdk/schemas/utils/ByteBuddyUtils.java | 4 +-
.../beam/sdk/schemas/utils/JavaBeanUtils.java | 11 +-
.../apache/beam/sdk/schemas/utils/POJOUtils.java | 10 +-
.../sdk/schemas/utils/SelectByteBuddyHelpers.java | 7 +-
.../reflect/ByteBuddyOnTimerInvokerFactory.java | 10 +-
.../org/apache/beam/sdk/util/ByteBuddyUtils.java | 57 +++++
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 257 +++++++++++++++++----
.../harness/data/PCollectionConsumerRegistry.java | 10 +-
sdks/java/io/cdap/README.md | 2 +-
sdks/java/io/sparkreceiver/2/README.md | 2 +-
.../content/en/documentation/io/built-in/cdap.md | 2 +-
.../content/en/documentation/programming-guide.md | 2 +-
.../site/content/en/get-started/quickstart-go.md | 2 +-
38 files changed, 374 insertions(+), 147 deletions(-)
copy learning/katas/go/windowing/adding_timestamp/pardo/pkg/task/task.go => sdks/go/pkg/beam/runners/prism/internal/engine/strategy.go (59%)
copy sdks/go/pkg/beam/{core/graph/coder/time_test.go => runners/prism/internal/engine/strategy_test.go} (52%)
create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/util/ByteBuddyUtils.java