This closes #1670: Fixes for direct runner expansion and evaluation of stateful ParDo
Actually propagate and commit state in direct runner Fix windowing in direct runner Stateful ParDo Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ff395169 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ff395169 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/ff395169 Branch: refs/heads/master Commit: ff395169993d84cd920be21f11d9a5555f8f8d8b Parents: 7ee8c86 55176c3 Author: Kenneth Knowles <k...@google.com> Authored: Wed Dec 21 13:11:54 2016 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Wed Dec 21 13:11:54 2016 -0800 ---------------------------------------------------------------------- .../direct/ParDoMultiOverrideFactory.java | 34 ++++++++++++++++++-- .../direct/StatefulParDoEvaluatorFactory.java | 1 + 2 files changed, 32 insertions(+), 3 deletions(-) ----------------------------------------------------------------------
