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/05/16 19:56:04 UTC
[2/2] incubator-beam git commit: This closes #338
This closes #338
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/638cc207
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/638cc207
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/638cc207
Branch: refs/heads/master
Commit: 638cc20719cb314d9e6b29fa79d45edcf4586dce
Parents: 0f2e6f3 62f05d8
Author: bchambers <bc...@google.com>
Authored: Mon May 16 12:44:19 2016 -0700
Committer: bchambers <bc...@google.com>
Committed: Mon May 16 12:44:19 2016 -0700
----------------------------------------------------------------------
.../DataflowPipelineTranslatorTest.java | 2 +
.../java/org/apache/beam/sdk/io/AvroIO.java | 28 +++++++++----
.../java/org/apache/beam/sdk/io/BigQueryIO.java | 43 +++++++++++++-------
.../sdk/io/BoundedReadFromUnboundedSource.java | 9 ++--
.../apache/beam/sdk/io/CompressedSource.java | 9 ++--
.../org/apache/beam/sdk/io/CountingInput.java | 12 ++++--
.../org/apache/beam/sdk/io/DatastoreIO.java | 18 +++++---
.../org/apache/beam/sdk/io/FileBasedSink.java | 3 +-
.../org/apache/beam/sdk/io/FileBasedSource.java | 3 +-
.../apache/beam/sdk/io/OffsetBasedSource.java | 9 ++--
.../java/org/apache/beam/sdk/io/PubsubIO.java | 42 +++++++++++--------
.../main/java/org/apache/beam/sdk/io/Read.java | 6 ++-
.../java/org/apache/beam/sdk/io/TextIO.java | 25 ++++++++----
.../main/java/org/apache/beam/sdk/io/Write.java | 3 +-
.../java/org/apache/beam/sdk/io/XmlSink.java | 6 ++-
.../java/org/apache/beam/sdk/io/XmlSource.java | 9 ++--
.../sdk/transforms/ApproximateQuantiles.java | 6 ++-
.../beam/sdk/transforms/ApproximateUnique.java | 6 ++-
.../org/apache/beam/sdk/transforms/Combine.java | 15 ++++---
.../apache/beam/sdk/transforms/CombineFns.java | 3 +-
.../org/apache/beam/sdk/transforms/Filter.java | 3 +-
.../apache/beam/sdk/transforms/GroupByKey.java | 3 +-
.../transforms/IntraBundleParallelization.java | 6 ++-
.../apache/beam/sdk/transforms/MapElements.java | 3 +-
.../org/apache/beam/sdk/transforms/Max.java | 3 +-
.../org/apache/beam/sdk/transforms/Min.java | 3 +-
.../org/apache/beam/sdk/transforms/ParDo.java | 3 +-
.../apache/beam/sdk/transforms/Partition.java | 6 ++-
.../org/apache/beam/sdk/transforms/Sample.java | 6 ++-
.../org/apache/beam/sdk/transforms/Top.java | 6 ++-
.../transforms/windowing/CalendarWindows.java | 18 +++++---
.../sdk/transforms/windowing/FixedWindows.java | 6 ++-
.../beam/sdk/transforms/windowing/Sessions.java | 3 +-
.../transforms/windowing/SlidingWindows.java | 9 ++--
.../beam/sdk/transforms/windowing/Window.java | 18 +++++---
.../beam/sdk/io/gcp/bigtable/BigtableIO.java | 15 ++++---
36 files changed, 243 insertions(+), 125 deletions(-)
----------------------------------------------------------------------