This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 2f2e4fa Merge pull request #15922 from ibzib/es-flake
add 7ebccbc [BEAM-11097] Create hook to enable cross-bundle side input
caching (#15896)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
.../runtime/harness/{sampler.go => cache_hooks.go} | 45 ++++++++++++----------
sdks/go/pkg/beam/core/runtime/harness/harness.go | 14 ++++---
.../core/runtime/harness/statecache/statecache.go | 20 +++++++++-
.../runtime/harness/statecache/statecache_test.go | 13 ++++++-
sdks/go/pkg/beam/util/harnessopts/cache.go | 42 ++++++++++++++++++++
.../harnessopts/cache_test.go} | 43 ++++++++++-----------
7 files changed, 128 insertions(+), 50 deletions(-)
copy sdks/go/pkg/beam/core/runtime/harness/{sampler.go => cache_hooks.go} (58%)
create mode 100644 sdks/go/pkg/beam/util/harnessopts/cache.go
copy sdks/go/pkg/beam/{core/runtime/xlangx/payload_test.go =>
util/harnessopts/cache_test.go} (51%)
