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/05/25 21:30:17 UTC

[2/2] incubator-beam git commit: This closes #361

This closes #361


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bde2a856
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bde2a856
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/bde2a856

Branch: refs/heads/master
Commit: bde2a856f1652f6ebab7aae2d5e78eeb4683a15a
Parents: 9f97ea0 928a302
Author: Kenneth Knowles <kl...@google.com>
Authored: Wed May 25 14:16:54 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Wed May 25 14:16:54 2016 -0700

----------------------------------------------------------------------
 sdks/java/core/pom.xml                          |  2 +-
 .../apache/beam/sdk/testing/NeedsRunner.java    | 28 ++++++++++++++++++++
 .../beam/sdk/testing/RunnableOnService.java     |  2 +-
 .../java/org/apache/beam/sdk/PipelineTest.java  |  2 ++
 .../apache/beam/sdk/coders/AvroCoderTest.java   |  3 +++
 .../beam/sdk/coders/CoderRegistryTest.java      |  4 +++
 .../beam/sdk/io/AvroIOGeneratedClassTest.java   |  9 +++++++
 .../java/org/apache/beam/sdk/io/AvroIOTest.java |  7 ++++-
 .../org/apache/beam/sdk/io/BigQueryIOTest.java  | 11 +++++---
 .../beam/sdk/io/CompressedSourceTest.java       | 15 +++++++++++
 .../apache/beam/sdk/io/CountingInputTest.java   |  2 ++
 .../apache/beam/sdk/io/CountingSourceTest.java  |  3 +++
 .../apache/beam/sdk/io/FileBasedSourceTest.java |  5 +++-
 .../beam/sdk/io/PubsubUnboundedSinkTest.java    |  5 ++++
 .../java/org/apache/beam/sdk/io/TextIOTest.java | 15 +++++++++++
 .../java/org/apache/beam/sdk/io/WriteTest.java  |  6 +++++
 .../org/apache/beam/sdk/io/XmlSourceTest.java   | 10 ++++---
 .../beam/sdk/runners/TransformTreeTest.java     |  3 +++
 .../transforms/ApproximateQuantilesTest.java    |  7 ++++-
 .../sdk/transforms/ApproximateUniqueTest.java   |  6 +++++
 .../apache/beam/sdk/transforms/CombineTest.java |  4 +--
 .../apache/beam/sdk/transforms/DoFnTest.java    |  7 ++++-
 .../sdk/transforms/DoFnWithContextTest.java     |  7 ++++-
 .../apache/beam/sdk/transforms/FilterTest.java  |  4 +++
 .../sdk/transforms/FlatMapElementsTest.java     |  5 ++++
 .../apache/beam/sdk/transforms/FlattenTest.java |  4 +++
 .../beam/sdk/transforms/GroupByKeyTest.java     |  5 +++-
 .../IntraBundleParallelizationTest.java         |  6 ++++-
 .../beam/sdk/transforms/MapElementsTest.java    |  7 ++++-
 .../apache/beam/sdk/transforms/ParDoTest.java   | 21 +++++++++++++--
 .../beam/sdk/transforms/PartitionTest.java      |  5 +++-
 .../apache/beam/sdk/transforms/SampleTest.java  |  3 ++-
 .../org/apache/beam/sdk/transforms/TopTest.java |  5 ++++
 .../apache/beam/sdk/transforms/ViewTest.java    |  4 +++
 .../beam/sdk/transforms/WithKeysTest.java       |  5 ++++
 .../beam/sdk/transforms/WithTimestampsTest.java |  3 +++
 .../sdk/transforms/join/CoGroupByKeyTest.java   |  2 ++
 .../sdk/transforms/windowing/WindowingTest.java |  3 +++
 .../org/apache/beam/sdk/values/PDoneTest.java   |  2 ++
 39 files changed, 225 insertions(+), 22 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/bde2a856/sdks/java/core/src/test/java/org/apache/beam/sdk/io/BigQueryIOTest.java
----------------------------------------------------------------------