This is an automated email from the ASF dual-hosted git repository. jkff pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 06887741135cfbf93e82bd7f22670d22fa938d1b Merge: 279a056 1207c28 Author: Eugene Kirpichov <[email protected]> AuthorDate: Thu Jun 28 11:28:46 2018 -0700 Merge pull request #5814: [BEAM-4285] Extend side input handlers to handle multiple access patterns. [BEAM-4285] Extend side input handlers to handle multiple access patterns. .../core/construction/PTransformTranslation.java | 5 + .../BatchFlinkExecutableStageContext.java | 8 +- .../FlinkBatchSideInputHandlerFactory.java | 106 +++++++++++++++++--- .../FlinkBatchSideInputHandlerFactoryTest.java | 93 +++++++++++++---- .../control/ProcessBundleDescriptors.java | 79 ++++++++------- .../fnexecution/state/StateRequestHandlers.java | 111 +++++++++++---------- .../fnexecution/control/RemoteExecutionTest.java | 25 +++-- 7 files changed, 289 insertions(+), 138 deletions(-)
