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