This closes #258
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/97945648 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/97945648 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/97945648 Branch: refs/heads/master Commit: 97945648c8efbaaea6780ec1b6027c6b5be7527f Parents: 32970c9 f57c1dc Author: Kenneth Knowles <k...@google.com> Authored: Wed May 4 10:52:19 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Wed May 4 10:52:19 2016 -0700 ---------------------------------------------------------------------- .../direct/InProcessEvaluationContext.java | 11 +- .../direct/InProcessSideInputContainer.java | 2 +- .../direct/InProcessSideInputContainerTest.java | 2 +- .../sdk/util/PushbackSideInputDoFnRunner.java | 115 +++++++++ .../sdk/util/ReadyCheckingSideInputReader.java | 34 +++ .../sdk/util/IdentitySideInputWindowFn.java | 54 +++++ .../util/PushbackSideInputDoFnRunnerTest.java | 234 +++++++++++++++++++ 7 files changed, 440 insertions(+), 12 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/97945648/runners/direct-java/src/main/java/org/apache/beam/runners/direct/InProcessEvaluationContext.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/97945648/runners/direct-java/src/main/java/org/apache/beam/runners/direct/InProcessSideInputContainer.java ----------------------------------------------------------------------
