This closes #2601

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

Branch: refs/heads/master
Commit: 781c15522d188c461e991515173304b94b1190ae
Parents: 62f041e dffa6a8
Author: Eugene Kirpichov <kirpic...@google.com>
Authored: Fri Apr 21 16:53:58 2017 -0700
Committer: Eugene Kirpichov <kirpic...@google.com>
Committed: Fri Apr 21 16:53:58 2017 -0700

----------------------------------------------------------------------
 .../translation/ReadUnboundTranslatorTest.java  |   6 +-
 .../EmptyFlattenAsCreateFactoryTest.java        |  10 +-
 .../core/construction/PCollectionsTest.java     |   6 +-
 .../PTransformReplacementsTest.java             |   4 +-
 .../core/construction/PTransformsTest.java      |  17 +-
 .../core/construction/SdkComponentsTest.java    |  16 +-
 .../runners/direct/DirectGraphVisitorTest.java  |   6 +-
 .../beam/runners/direct/DirectRunnerTest.java   |  10 +-
 .../runners/direct/EvaluationContextTest.java   |   4 +-
 .../beam/runners/flink/ReadSourceITCase.java    |   4 +-
 .../flink/ReadSourceStreamingITCase.java        |   4 +-
 .../streaming/StreamingSourceMetricsTest.java   |   7 +-
 .../org/apache/beam/sdk/io/CountingInput.java   | 283 -------------------
 .../org/apache/beam/sdk/io/CountingSource.java  |  47 +--
 .../apache/beam/sdk/io/GenerateSequence.java    | 194 +++++++++++++
 .../org/apache/beam/sdk/values/PCollection.java |   9 +-
 .../java/org/apache/beam/sdk/PipelineTest.java  |  58 ++--
 .../apache/beam/sdk/io/CountingInputTest.java   | 221 ---------------
 .../apache/beam/sdk/io/CountingSourceTest.java  |   4 +-
 .../beam/sdk/io/GenerateSequenceTest.java       | 194 +++++++++++++
 .../apache/beam/sdk/metrics/MetricsTest.java    |  12 +-
 .../sdk/runners/TransformHierarchyTest.java     |   7 +-
 .../beam/sdk/testing/GatherAllPanesTest.java    |   8 +-
 .../apache/beam/sdk/testing/PAssertTest.java    |  12 +-
 .../apache/beam/sdk/transforms/FlattenTest.java |   8 +-
 .../apache/beam/sdk/transforms/ParDoTest.java   |   4 +-
 .../sdk/transforms/windowing/WindowTest.java    |   4 +-
 .../beam/sdk/values/PCollectionListTest.java    |  25 +-
 .../beam/sdk/values/PCollectionTupleTest.java   |   6 +-
 .../sdk/io/gcp/bigquery/BigQueryIOTest.java     |   6 +-
 .../sdk/io/gcp/bigtable/BigtableWriteIT.java    |   4 +-
 .../beam/sdk/io/gcp/datastore/V1WriteIT.java    |   4 +-
 32 files changed, 540 insertions(+), 664 deletions(-)
----------------------------------------------------------------------


Reply via email to