Repository: incubator-beam Updated Branches: refs/heads/master 89367cfb1 -> d93ef2edd
Closes #756 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d93ef2ed Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d93ef2ed Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d93ef2ed Branch: refs/heads/master Commit: d93ef2edd260a2077bc2ba6abd1ca02abd147a9a Parents: 89367cf 236945d Author: bchambers <bchamb...@google.com> Authored: Wed Aug 17 16:09:01 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Wed Aug 17 16:09:01 2016 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/transforms/Combine.java | 28 ++++++++++---------- .../org/apache/beam/sdk/transforms/Count.java | 8 +++--- .../beam/sdk/transforms/FlatMapElements.java | 4 +-- .../org/apache/beam/sdk/transforms/Flatten.java | 12 ++++----- .../org/apache/beam/sdk/transforms/Keys.java | 8 +++--- .../org/apache/beam/sdk/transforms/KvSwap.java | 9 +++---- .../apache/beam/sdk/transforms/MapElements.java | 16 ++++++++--- .../beam/sdk/transforms/RemoveDuplicates.java | 8 +++--- .../org/apache/beam/sdk/transforms/Values.java | 8 +++--- .../apache/beam/sdk/transforms/WithKeys.java | 9 +++---- .../beam/sdk/transforms/windowing/Window.java | 11 ++++---- .../java/org/apache/beam/sdk/PipelineTest.java | 12 ++++----- .../java/org/apache/beam/sdk/io/WriteTest.java | 4 ++- .../beam/sdk/transforms/MapElementsTest.java | 8 +++--- .../org/apache/beam/sdk/io/kafka/KafkaIO.java | 10 ++++--- 15 files changed, 81 insertions(+), 74 deletions(-) ----------------------------------------------------------------------
