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(-) ----------------------------------------------------------------------
