Repository: beam Updated Branches: refs/heads/master 018513e58 -> 8b119bcdf
This closes #2380 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8b119bcd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8b119bcd Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8b119bcd Branch: refs/heads/master Commit: 8b119bcdf2271b3cd39a05a539d8c27c56d2f77e Parents: 018513e d174a24 Author: Thomas Groh <[email protected]> Authored: Mon Apr 3 11:45:51 2017 -0700 Committer: Thomas Groh <[email protected]> Committed: Mon Apr 3 11:45:51 2017 -0700 ---------------------------------------------------------------------- .../flink/FlinkStreamingPipelineTranslator.java | 81 +++++++++++--------- 1 file changed, 43 insertions(+), 38 deletions(-) ----------------------------------------------------------------------
