beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [beam] branch master updated (e45a07c -> 5b4ea81)
Date Thu, 02 Jan 2020 22:10:16 GMT
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 e45a07c  Merge pull request #10469: [BEAM-9034] Update environment_id for ExternalTransform
in Python SDK
     add 5b4ea81  [BEAM-5600] Add unimplemented split API to Runner side SDF libraries. (#10482)

No new revisions were added by this update.

Summary of changes:
 .../FlinkExecutableStageFunctionTest.java          |   5 +
 .../streaming/ExecutableStageDoFnOperatorTest.java |   5 +
 .../fnexecution/control/BundleSplitHandler.java    |  46 ++++
 .../control/DefaultJobBundleFactory.java           |   5 +
 .../runners/fnexecution/control/RemoteBundle.java  |   9 +
 .../fnexecution/control/SdkHarnessClient.java      | 283 +++++++++++++--------
 .../fnexecution/control/RemoteExecutionTest.java   |  19 +-
 .../fnexecution/control/SdkHarnessClientTest.java  |  26 +-
 .../SparkExecutableStageFunctionTest.java          |   5 +
 9 files changed, 274 insertions(+), 129 deletions(-)
 create mode 100644 runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/BundleSplitHandler.java


Mime
View raw message