This is an automated email from the ASF dual-hosted git repository.
jkff pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from a5b2382 Merge pull request #5650 from robertwb/import-2018-06-14
add 943b8f0 Removed some dead code, fixed some warnings
add 436fceb Adds tracing of watermarks in direct runner
add 01368f9 Fixes typo in class name
add af83aa3 Simplifies GBK expansion code a bit
add 990d2ec Fixes bug: Processes values arriving for a GBK key
sequentially
add e25243a Introduces BundleProgressHandler.
add b057fb8 [BEAM-4473,BEAM-4281] Makes ReferenceRunner use a Direct
stream observer factory for synchronization
add 6411964 Merge pull request #5585: Various smaller-scale changes
extracted while working on SDF
No new revisions were added by this update.
Summary of changes:
.../core/SplittableParDoViaKeyedWorkItems.java | 7 -
.../beam/runners/direct/EvaluationContext.java | 2 +-
.../beam/runners/direct/WatermarkManager.java | 98 ++++++-
...ava => BundleFactoryOutputReceiverFactory.java} | 6 +-
.../runners/direct/portable/EvaluationContext.java | 2 +-
.../runners/direct/portable/ReferenceRunner.java | 149 ++++++----
.../portable/RemoteStageEvaluatorFactory.java | 6 +-
.../beam/runners/direct/WatermarkManagerTest.java | 6 +-
...=> BundleFactoryOutputReceiverFactoryTest.java} | 6 +-
.../direct/portable/ReferenceRunnerTest.java | 35 +++
.../portable/RemoteStageEvaluatorFactoryTest.java | 5 +-
.../functions/FlinkExecutableStageFunction.java | 5 +-
.../streaming/ExecutableStageDoFnOperator.java | 9 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 8 +-
.../FlinkExecutableStageFunctionTest.java | 8 +-
.../fnexecution/control/BundleProgressHandler.java | 54 ++++
.../control/DockerJobBundleFactory.java | 10 +-
.../runners/fnexecution/control/RemoteBundle.java | 6 +-
.../fnexecution/control/SdkHarnessClient.java | 27 +-
.../SingleEnvironmentInstanceJobBundleFactory.java | 5 +-
.../fnexecution/control/StageBundleFactory.java | 3 +-
.../runners/fnexecution/data/GrpcDataService.java | 14 +-
.../environment/InProcessEnvironmentFactory.java | 4 +-
.../runners/fnexecution/InProcessSdkHarness.java | 5 +-
.../fnexecution/control/RemoteExecutionTest.java | 16 +-
.../fnexecution/control/SdkHarnessClientTest.java | 63 +++--
...gleEnvironmentInstanceJobBundleFactoryTest.java | 5 +-
.../fnexecution/data/GrpcDataServiceTest.java | 17 +-
.../sdk/fn/data/BeamFnDataGrpcMultiplexer.java | 9 +-
.../sdk/fn/stream/OutboundObserverFactory.java | 146 ++++++++++
.../beam/sdk/fn/stream/StreamObserverFactory.java | 115 --------
.../sdk/fn/data/BeamFnDataGrpcMultiplexerTest.java | 9 +-
...yTest.java => OutboundObserverFactoryTest.java} | 18 +-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 313 ++++-----------------
.../java/org/apache/beam/fn/harness/FnHarness.java | 22 +-
.../fn/harness/control/BeamFnControlClient.java | 12 +-
.../beam/fn/harness/data/BeamFnDataGrpcClient.java | 23 +-
.../harness/state/BeamFnStateGrpcClientCache.java | 22 +-
.../stream/HarnessStreamObserverFactories.java | 10 +-
.../harness/control/BeamFnControlClientTest.java | 11 +-
.../fn/harness/data/BeamFnDataGrpcClientTest.java | 31 +-
.../state/BeamFnStateGrpcClientCacheTest.java | 11 +-
.../stream/HarnessStreamObserverFactoriesTest.java | 6 +-
43 files changed, 691 insertions(+), 648 deletions(-)
rename
runners/direct-java/src/main/java/org/apache/beam/runners/direct/portable/{BundleFactoryOutputRecieverFactory.java
=> BundleFactoryOutputReceiverFactory.java} (94%)
rename
runners/direct-java/src/test/java/org/apache/beam/runners/direct/portable/{BundleFactoryOutputRecieverFactoryTest.java
=> BundleFactoryOutputReceiverFactoryTest.java} (98%)
create mode 100644
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/BundleProgressHandler.java
create mode 100644
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java
delete mode 100644
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/StreamObserverFactory.java
rename
sdks/java/fn-execution/src/test/java/org/apache/beam/sdk/fn/stream/{StreamObserverFactoryTest.java
=> OutboundObserverFactoryTest.java} (78%)
--
To stop receiving notification emails like this one, please contact
[email protected].
