This closes #1435
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8d1214a3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8d1214a3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8d1214a3 Branch: refs/heads/master Commit: 8d1214a3ba94b21102b74d346e73f24ecd9056f2 Parents: 3e4b2fd 4a09772 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Thu Nov 24 15:20:49 2016 +0100 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Thu Nov 24 15:20:49 2016 +0100 ---------------------------------------------------------------------- .../FlinkStreamingTransformTranslators.java | 63 +++----------------- 1 file changed, 9 insertions(+), 54 deletions(-) ----------------------------------------------------------------------