You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/08/05 03:10:51 UTC
[9/9] incubator-beam git commit: This closes #782
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 <kl...@google.com>
Authored: Thu Aug 4 20:10:55 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
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(-)
----------------------------------------------------------------------