You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bc...@apache.org on 2016/04/26 19:11:58 UTC
[4/4] incubator-beam git commit: This closes #241
This closes #241
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7dc1a404
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7dc1a404
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7dc1a404
Branch: refs/heads/master
Commit: 7dc1a4047c8a145377c26ed73163a28f7b8835dd
Parents: d299e2c c6690c1
Author: bchambers <bc...@google.com>
Authored: Tue Apr 26 09:39:06 2016 -0700
Committer: bchambers <bc...@google.com>
Committed: Tue Apr 26 09:39:06 2016 -0700
----------------------------------------------------------------------
.../org/apache/beam/sdk/io/DatastoreIO.java | 1 +
.../main/java/org/apache/beam/sdk/io/Read.java | 2 +
.../main/java/org/apache/beam/sdk/io/Sink.java | 2 +-
.../java/org/apache/beam/sdk/io/Source.java | 2 +-
.../main/java/org/apache/beam/sdk/io/Write.java | 1 +
.../sdk/transforms/ApproximateQuantiles.java | 1 +
.../beam/sdk/transforms/ApproximateUnique.java | 2 +
.../org/apache/beam/sdk/transforms/Combine.java | 11 ++++
.../beam/sdk/transforms/CombineFnBase.java | 4 +-
.../apache/beam/sdk/transforms/CombineFns.java | 4 ++
.../beam/sdk/transforms/CombineWithContext.java | 1 +
.../org/apache/beam/sdk/transforms/DoFn.java | 2 +-
.../beam/sdk/transforms/DoFnWithContext.java | 2 +-
.../org/apache/beam/sdk/transforms/Filter.java | 4 ++
.../apache/beam/sdk/transforms/GroupByKey.java | 1 +
.../transforms/IntraBundleParallelization.java | 1 +
.../org/apache/beam/sdk/transforms/Max.java | 1 +
.../org/apache/beam/sdk/transforms/Min.java | 1 +
.../apache/beam/sdk/transforms/PTransform.java | 2 +-
.../org/apache/beam/sdk/transforms/ParDo.java | 4 +-
.../apache/beam/sdk/transforms/Partition.java | 2 +
.../org/apache/beam/sdk/transforms/Sample.java | 2 +
.../org/apache/beam/sdk/transforms/Top.java | 1 +
.../sdk/transforms/display/ClassForDisplay.java | 4 +-
.../sdk/transforms/display/DisplayData.java | 58 ++++++++++----------
.../sdk/transforms/display/HasDisplayData.java | 8 +--
.../transforms/windowing/CalendarWindows.java | 6 ++
.../sdk/transforms/windowing/FixedWindows.java | 1 +
.../beam/sdk/transforms/windowing/Sessions.java | 1 +
.../transforms/windowing/SlidingWindows.java | 1 +
.../beam/sdk/transforms/windowing/Window.java | 1 +
.../beam/sdk/transforms/windowing/WindowFn.java | 2 +-
.../org/apache/beam/sdk/util/CombineFnUtil.java | 1 +
.../io/BoundedReadFromUnboundedSourceTest.java | 5 +-
.../beam/sdk/io/CompressedSourceTest.java | 5 +-
.../java/org/apache/beam/sdk/io/ReadTest.java | 6 +-
.../java/org/apache/beam/sdk/io/WriteTest.java | 5 +-
.../beam/sdk/transforms/CombineFnsTest.java | 6 +-
.../apache/beam/sdk/transforms/CombineTest.java | 4 +-
.../IntraBundleParallelizationTest.java | 4 +-
.../apache/beam/sdk/transforms/ParDoTest.java | 8 +--
.../transforms/display/DisplayDataMatchers.java | 14 ++---
.../display/DisplayDataMatchersTest.java | 4 +-
.../sdk/transforms/display/DisplayDataTest.java | 6 +-
.../sdk/transforms/windowing/WindowTest.java | 4 +-
45 files changed, 130 insertions(+), 78 deletions(-)
----------------------------------------------------------------------