This closes #1520
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6807480a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6807480a Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/6807480a Branch: refs/heads/master Commit: 6807480a97f2315b3f48ad8dd5accb4e30475fa4 Parents: c53e0b1 f1a5704 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Thu Dec 8 09:55:32 2016 +0800 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Thu Dec 8 09:55:32 2016 +0800 ---------------------------------------------------------------------- .../FlinkStreamingTransformTranslators.java | 28 +++++++++++++------- 1 file changed, 18 insertions(+), 10 deletions(-) ----------------------------------------------------------------------
