This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 543abed Merge pull request #10163 from ibzib/artifact-port
add 4c18cb4 [BEAM-7948] Add time-based cache threshold support in the
Java data s… (#9949)
No new revisions were added by this update.
Summary of changes:
.../worker/fn/data/BeamFnDataGrpcService.java | 35 +----
.../worker/fn/control/TimerReceiverTest.java | 5 +-
.../control/DefaultJobBundleFactory.java | 3 +-
.../runners/fnexecution/data/GrpcDataService.java | 19 ++-
.../runners/fnexecution/EmbeddedSdkHarness.java | 3 +-
.../fnexecution/control/RemoteExecutionTest.java | 5 +-
...gleEnvironmentInstanceJobBundleFactoryTest.java | 4 +-
.../fnexecution/data/GrpcDataServiceTest.java | 9 +-
.../beam/runners/samza/SamzaExecutionContext.java | 3 +-
.../data/BeamFnDataBufferingOutboundObserver.java | 146 +++++++--------------
...mFnDataSizeBasedBufferingOutboundObserver.java} | 44 ++-----
...amFnDataTimeBasedBufferingOutboundObserver.java | 116 ++++++++++++++++
...ataSizeBasedBufferingOutboundObserverTest.java} | 36 +++--
...DataTimeBasedBufferingOutboundObserverTest.java | 138 +++++++++++++++++++
.../beam/fn/harness/data/BeamFnDataGrpcClient.java | 27 +---
.../fn/harness/data/BeamFnDataGrpcClientTest.java | 2 +-
16 files changed, 382 insertions(+), 213 deletions(-)
copy
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/{BeamFnDataBufferingOutboundObserver.java
=> BeamFnDataSizeBasedBufferingOutboundObserver.java} (69%)
create mode 100644
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataTimeBasedBufferingOutboundObserver.java
rename
sdks/java/fn-execution/src/test/java/org/apache/beam/sdk/fn/data/{BeamFnDataBufferingOutboundObserverTest.java
=> BeamFnDataSizeBasedBufferingOutboundObserverTest.java} (80%)
create mode 100644
sdks/java/fn-execution/src/test/java/org/apache/beam/sdk/fn/data/BeamFnDataTimeBasedBufferingOutboundObserverTest.java
