This closes #2157: Port Java modules from RunnableOnService to ValidatesRunner
Remove deprecated RunnableOnService Port Java modules from RunnableOnService to ValidatesRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1d36d32f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1d36d32f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1d36d32f Branch: refs/heads/master Commit: 1d36d32fea68e067a631a15143377e58f75da7d4 Parents: 61fad2a 488dc99 Author: Kenneth Knowles <[email protected]> Authored: Mon Mar 27 11:14:21 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Mon Mar 27 11:14:21 2017 -0700 ---------------------------------------------------------------------- examples/java/pom.xml | 2 +- .../org/apache/beam/examples/WordCountTest.java | 4 +- .../beam/examples/complete/TfIdfTest.java | 4 +- .../complete/TopWikipediaSessionsTest.java | 4 +- .../examples/cookbook/DistinctExampleTest.java | 6 +- .../examples/cookbook/JoinExamplesTest.java | 4 +- .../examples/cookbook/TriggerExampleTest.java | 4 +- examples/java8/pom.xml | 2 +- .../examples/complete/game/GameStatsTest.java | 4 +- .../complete/game/HourlyTeamScoreTest.java | 4 +- .../examples/complete/game/UserScoreTest.java | 8 +-- runners/apex/pom.xml | 4 +- runners/flink/runner/pom.xml | 6 +- .../runners/dataflow/testing/package-info.java | 2 +- runners/pom.xml | 2 +- runners/spark/pom.xml | 6 +- .../beam/sdk/testing/RunnableOnService.java | 38 ----------- .../apache/beam/sdk/testing/TestPipeline.java | 6 +- .../beam/sdk/testing/ValidatesRunner.java | 23 +++++++ .../java/org/apache/beam/sdk/PipelineTest.java | 10 +-- .../java/org/apache/beam/sdk/io/AvroIOTest.java | 8 +-- .../io/BoundedReadFromUnboundedSourceTest.java | 8 +-- .../apache/beam/sdk/io/CountingInputTest.java | 14 ++-- .../apache/beam/sdk/io/CountingSourceTest.java | 14 ++-- .../org/apache/beam/sdk/io/PubsubIOTest.java | 6 +- .../java/org/apache/beam/sdk/io/ReadTest.java | 6 +- .../java/org/apache/beam/sdk/io/TextIOTest.java | 10 +-- .../apache/beam/sdk/metrics/MetricsTest.java | 6 +- .../apache/beam/sdk/testing/PAssertTest.java | 34 +++++----- .../beam/sdk/testing/TestPipelineTest.java | 24 +++---- .../sdk/transforms/ApproximateUniqueTest.java | 4 +- .../beam/sdk/transforms/CombineFnsTest.java | 8 +-- .../apache/beam/sdk/transforms/CombineTest.java | 44 ++++++------ .../apache/beam/sdk/transforms/CountTest.java | 10 +-- .../apache/beam/sdk/transforms/CreateTest.java | 18 ++--- .../beam/sdk/transforms/DistinctTest.java | 8 +-- .../apache/beam/sdk/transforms/FilterTest.java | 16 ++--- .../apache/beam/sdk/transforms/FlattenTest.java | 30 ++++----- .../beam/sdk/transforms/GroupByKeyTest.java | 14 ++-- .../apache/beam/sdk/transforms/KeysTest.java | 6 +- .../apache/beam/sdk/transforms/KvSwapTest.java | 6 +- .../beam/sdk/transforms/MapElementsTest.java | 4 +- .../beam/sdk/transforms/ParDoLifecycleTest.java | 10 +-- .../apache/beam/sdk/transforms/ParDoTest.java | 68 +++++++++---------- .../beam/sdk/transforms/PartitionTest.java | 4 +- .../apache/beam/sdk/transforms/SampleTest.java | 14 ++-- .../beam/sdk/transforms/SplittableDoFnTest.java | 14 ++-- .../beam/sdk/transforms/ToStringTest.java | 13 ++-- .../apache/beam/sdk/transforms/ValuesTest.java | 6 +- .../apache/beam/sdk/transforms/ViewTest.java | 70 ++++++++++---------- .../beam/sdk/transforms/WithTimestampsTest.java | 8 +-- .../sdk/transforms/join/CoGroupByKeyTest.java | 10 +-- .../sdk/transforms/windowing/WindowTest.java | 10 +-- .../sdk/transforms/windowing/WindowingTest.java | 10 +-- .../beam/sdk/util/ReifyTimestampsTest.java | 6 +- .../org/apache/beam/sdk/util/ReshuffleTest.java | 16 ++--- .../beam/sdk/values/PCollectionTupleTest.java | 4 +- .../org/apache/beam/sdk/values/PDoneTest.java | 4 +- .../io/elasticsearch/ElasticsearchIOTest.java | 8 +-- .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 18 ++--- .../sdk/io/gcp/datastore/DatastoreV1Test.java | 8 +-- .../org/apache/beam/sdk/io/mqtt/MqttIOTest.java | 9 ++- .../beam/sdk/transforms/FilterJava8Test.java | 8 +-- .../beam/sdk/transforms/WithKeysJava8Test.java | 4 +- .../sdk/transforms/WithTimestampsJava8Test.java | 4 +- 65 files changed, 375 insertions(+), 392 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/1d36d32f/sdks/java/core/src/test/java/org/apache/beam/sdk/metrics/MetricsTest.java ----------------------------------------------------------------------
