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 <bchamb...@google.com> Authored: Mon May 16 12:44:19 2016 -0700 Committer: bchambers <bchamb...@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(-) ----------------------------------------------------------------------