This closes #2030: Convert to/from WindowingStrategy proto in Java SDK Add conversion to/from Runner API proto for WindowingStrategy Add closing behavior to Runner API proto Make SDK-specific serialized blob really a blob
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/154c5430 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/154c5430 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/154c5430 Branch: refs/heads/master Commit: 154c543057b54ca46975cb9e9d360a52784518d7 Parents: 3fcc820 7dd5710 Author: Kenneth Knowles <k...@google.com> Authored: Tue Feb 21 13:09:17 2017 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Tue Feb 21 13:09:17 2017 -0800 ---------------------------------------------------------------------- .../src/main/proto/beam_runner_api.proto | 19 +- .../sdk/transforms/windowing/GlobalWindows.java | 10 + .../sdk/transforms/windowing/OutputTimeFns.java | 45 ++++ .../beam/sdk/transforms/windowing/Window.java | 3 +- .../beam/sdk/util/WindowingStrategies.java | 241 +++++++++++++++++++ .../apache/beam/sdk/util/WindowingStrategy.java | 53 +++- .../transforms/windowing/OutputTimeFnsTest.java | 51 ++++ .../beam/sdk/util/WindowingStrategiesTest.java | 91 +++++++ 8 files changed, 507 insertions(+), 6 deletions(-) ----------------------------------------------------------------------
