This closes #982
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6082ebcc Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6082ebcc Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/6082ebcc Branch: refs/heads/master Commit: 6082ebccedec076140720aefdb8f35e263847082 Parents: 8432752 b1474a1 Author: Sela <ans...@paypal.com> Authored: Thu Sep 22 18:19:43 2016 +0300 Committer: Sela <ans...@paypal.com> Committed: Thu Sep 22 18:19:43 2016 +0300 ---------------------------------------------------------------------- .../streaming/StreamingTransformTranslator.java | 28 +++++------ .../streaming/SimpleStreamingWordCountTest.java | 49 +++++++++++++------- 2 files changed, 46 insertions(+), 31 deletions(-) ----------------------------------------------------------------------
