You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/04/21 23:56:20 UTC
[5/5] beam git commit: This closes #2601
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 <ki...@google.com>
Authored: Fri Apr 21 16:53:58 2017 -0700
Committer: Eugene Kirpichov <ki...@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(-)
----------------------------------------------------------------------