This closes #782
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8daf518b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8daf518b Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8daf518b Branch: refs/heads/master Commit: 8daf518bccfe425082c7d0b3f31f3623ff67e000 Parents: fcf6b1d 47341e1 Author: Kenneth Knowles <[email protected]> Authored: Thu Aug 4 20:10:55 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Thu Aug 4 20:10:55 2016 -0700 ---------------------------------------------------------------------- .../beam/runners/dataflow/DataflowRunner.java | 3 +- .../java/org/apache/beam/sdk/io/PubsubIO.java | 14 +++---- .../apache/beam/sdk/io/PubsubUnboundedSink.java | 17 ++++----- .../beam/sdk/io/PubsubUnboundedSource.java | 7 ++-- .../beam/sdk/options/PipelineOptions.java | 9 ++--- .../org/apache/beam/sdk/testing/PAssert.java | 39 ++++++++++---------- .../org/apache/beam/sdk/transforms/Count.java | 4 +- .../org/apache/beam/sdk/transforms/Create.java | 4 +- .../beam/sdk/transforms/DoFnReflector.java | 6 +++ .../beam/sdk/transforms/FlatMapElements.java | 4 +- .../org/apache/beam/sdk/transforms/Flatten.java | 4 +- .../org/apache/beam/sdk/transforms/Keys.java | 4 +- .../org/apache/beam/sdk/transforms/KvSwap.java | 4 +- .../apache/beam/sdk/transforms/MapElements.java | 4 +- .../org/apache/beam/sdk/transforms/ParDo.java | 2 +- .../apache/beam/sdk/transforms/Partition.java | 4 +- .../beam/sdk/transforms/RemoveDuplicates.java | 4 +- .../org/apache/beam/sdk/transforms/Sample.java | 6 +-- .../org/apache/beam/sdk/transforms/Values.java | 4 +- .../org/apache/beam/sdk/transforms/View.java | 8 ++-- .../apache/beam/sdk/transforms/WithKeys.java | 4 +- .../beam/sdk/transforms/WithTimestamps.java | 6 +-- .../beam/sdk/transforms/join/CoGroupByKey.java | 16 ++++---- .../java/org/apache/beam/sdk/PipelineTest.java | 8 ++-- .../apache/beam/sdk/coders/AvroCoderTest.java | 6 +-- .../beam/sdk/coders/CoderRegistryTest.java | 10 ++--- .../beam/sdk/coders/SerializableCoderTest.java | 10 ++--- .../apache/beam/sdk/io/CountingInputTest.java | 6 +-- .../apache/beam/sdk/io/CountingSourceTest.java | 6 +-- .../beam/sdk/io/PubsubUnboundedSinkTest.java | 6 +-- .../sdk/transforms/ApproximateUniqueTest.java | 6 +-- .../beam/sdk/transforms/CombineFnsTest.java | 4 +- .../apache/beam/sdk/transforms/CombineTest.java | 18 ++++----- .../apache/beam/sdk/transforms/CreateTest.java | 4 +- .../apache/beam/sdk/transforms/FlattenTest.java | 8 ++-- .../beam/sdk/transforms/GroupByKeyTest.java | 8 ++-- .../beam/sdk/transforms/WithTimestampsTest.java | 12 +++--- .../display/DisplayDataEvaluatorTest.java | 10 ++--- .../sdk/transforms/display/DisplayDataTest.java | 6 +-- .../sdk/transforms/join/CoGroupByKeyTest.java | 34 ++++++++--------- .../sdk/transforms/windowing/WindowTest.java | 10 ++--- .../sdk/transforms/windowing/WindowingTest.java | 23 ++++++------ .../beam/sdk/values/PCollectionTupleTest.java | 6 +-- .../apache/beam/sdk/values/TypedPValueTest.java | 10 ++--- .../beam/sdk/extensions/joinlibrary/Join.java | 14 +++---- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 36 +++++++++--------- .../beam/sdk/io/gcp/bigtable/BigtableIO.java | 12 +++--- .../beam/sdk/io/gcp/datastore/V1Beta3.java | 18 ++++----- .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 10 ++--- .../sdk/io/gcp/bigtable/BigtableWriteIT.java | 6 +-- .../sdk/io/gcp/datastore/V1Beta3TestUtil.java | 9 ++--- .../java/org/apache/beam/sdk/io/jms/JmsIO.java | 10 ++--- .../org/apache/beam/sdk/io/kafka/KafkaIO.java | 19 +++++----- .../apache/beam/sdk/io/kafka/KafkaIOTest.java | 10 ++--- 54 files changed, 265 insertions(+), 267 deletions(-) ----------------------------------------------------------------------
