This closes #147
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a32a2620 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a32a2620 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a32a2620 Branch: refs/heads/master Commit: a32a26208854a0875b10026d8f659ac275e37560 Parents: a43f9b8 42969cb Author: Kenneth Knowles <[email protected]> Authored: Fri Apr 8 17:04:03 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Fri Apr 8 17:04:03 2016 -0700 ---------------------------------------------------------------------- .../sdk/runners/DirectPipelineRunner.java | 47 ++++++++++++++++++++ .../inprocess/WindowEvaluatorFactory.java | 13 +++--- .../sdk/transforms/windowing/Window.java | 21 ++------- .../cloud/dataflow/sdk/util/AssignWindows.java | 46 +++++++++++++++++++ 4 files changed, 104 insertions(+), 23 deletions(-) ----------------------------------------------------------------------
