This closes #1174
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c03e3e92 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c03e3e92 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c03e3e92 Branch: refs/heads/gearpump-runner Commit: c03e3e926c38846ad02cf6d7bf857499927d54bd Parents: 79bb2c2 7239ebb Author: Kenneth Knowles <[email protected]> Authored: Tue Oct 25 10:46:43 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Tue Oct 25 10:46:43 2016 -0700 ---------------------------------------------------------------------- .../runners/direct/DoFnLifecycleManager.java | 56 +++++++++------ .../direct/DoFnLifecycleManagerTest.java | 74 ++++++++++++++++++-- 2 files changed, 104 insertions(+), 26 deletions(-) ----------------------------------------------------------------------
