This closes #3893 [BEAM-1037] Support for new State API in ApexRunner
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ea7940d8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ea7940d8 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ea7940d8 Branch: refs/heads/master Commit: ea7940d88d9d5ddb09fabc5c8993d8395c59abce Parents: 8479425 575e36e Author: Thomas Weise <[email protected]> Authored: Sat Sep 30 15:14:44 2017 -0700 Committer: Thomas Weise <[email protected]> Committed: Sat Sep 30 15:14:44 2017 -0700 ---------------------------------------------------------------------- runners/apex/pom.xml | 1 - .../apex/translation/ParDoTranslator.java | 24 ++------------------ .../operators/ApexParDoOperator.java | 22 ++++++++++++++---- .../translation/utils/ApexStateInternals.java | 13 ++++------- .../FlattenPCollectionTranslatorTest.java | 1 - .../apex/translation/ParDoTranslatorTest.java | 4 +--- 6 files changed, 25 insertions(+), 40 deletions(-) ----------------------------------------------------------------------
