beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [43/51] [abbrv] incubator-beam git commit: This closes #782
Date Sat, 06 Aug 2016 02:53:01 GMT
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/python-sdk
Commit: 8daf518bccfe425082c7d0b3f31f3623ff67e000
Parents: fcf6b1d 47341e1
Author: Kenneth Knowles <klk@google.com>
Authored: Thu Aug 4 20:10:55 2016 -0700
Committer: Kenneth Knowles <klk@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(-)
----------------------------------------------------------------------



Mime
View raw message