This closes #1664: [BEAM-1176] Migrating tests to use TestPipeline as a JUnit rule
Migrated the beam-sdks-java-io-java8tests module to TestPipeline as a JUnit rule + fixed WithTimestampsJava8Test.withTimestampsLambdaShouldApplyTimestamps. Migrated the beam-sdks-java-io-mongodb module to TestPipeline as a JUnit rule. Migrated the beam-sdks-java-io-kinesis module to TestPipeline as a JUnit rule. Migrated the beam-sdks-java-io-kafka module to TestPipeline as a JUnit rule. Migrated the beam-sdks-java-io-jms module to TestPipeline as a JUnit rule. Migrated the beam-sdks-java-io-jdbc module to TestPipeline as a JUnit rule. Migrated the beam-sdks-java-io-google-cloud-platform module to TestPipeline as a JUnit rule. Migrated the beam-sdks-java-extensions-sorter module to TestPipeline as a JUnit rule. Migrated the beam-sdks-java-extensions-join-library module to TestPipeline as a JUnit rule. Migrated the beam-sdks-java-core module to TestPipeline as a JUnit rule. Plus, fixed some checkstyle errors from previous modules' migration. Migrated the beam-runners-direct-java module to TestPipeline as a JUnit rule. Migrated the beam-runners-core module to TestPipeline as a JUnit rule. Migrated the beam-examples-java8 module to TestPipeline as a JUnit rule. Migrated the beam-examples-java module to TestPipeline as a JUnit rule. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/22e25a47 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/22e25a47 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/22e25a47 Branch: refs/heads/python-sdk Commit: 22e25a47e2edc7b7f702eaca12630f6de7195657 Parents: b3de17b 4b23d42 Author: Kenneth Knowles <k...@google.com> Authored: Tue Dec 20 09:55:57 2016 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Tue Dec 20 09:55:57 2016 -0800 ---------------------------------------------------------------------- .../org/apache/beam/examples/WordCountTest.java | 7 +- .../examples/complete/AutoCompleteTest.java | 11 +- .../beam/examples/complete/TfIdfTest.java | 6 +- .../complete/TopWikipediaSessionsTest.java | 7 +- .../examples/cookbook/DistinctExampleTest.java | 9 +- .../examples/cookbook/JoinExamplesTest.java | 6 +- .../examples/cookbook/TriggerExampleTest.java | 6 +- .../examples/MinimalWordCountJava8Test.java | 6 +- .../examples/complete/game/GameStatsTest.java | 7 +- .../complete/game/HourlyTeamScoreTest.java | 5 +- .../examples/complete/game/LeaderBoardTest.java | 11 +- .../examples/complete/game/UserScoreTest.java | 10 +- .../core/PushbackSideInputDoFnRunnerTest.java | 5 +- .../beam/runners/core/SplittableParDoTest.java | 10 +- .../UnboundedReadFromBoundedSourceTest.java | 6 +- .../direct/BoundedReadEvaluatorFactoryTest.java | 13 +- .../direct/CloningBundleFactoryTest.java | 8 +- .../runners/direct/CommittedResultTest.java | 6 +- .../CopyOnAccessInMemoryStateInternalsTest.java | 7 +- .../runners/direct/DirectGraphVisitorTest.java | 3 +- .../runners/direct/EvaluationContextTest.java | 7 +- .../direct/FlattenEvaluatorFactoryTest.java | 6 +- .../direct/GroupByKeyEvaluatorFactoryTest.java | 5 +- .../GroupByKeyOnlyEvaluatorFactoryTest.java | 5 +- .../ImmutabilityCheckingBundleFactoryTest.java | 4 +- .../ImmutabilityEnforcementFactoryTest.java | 3 +- .../direct/ImmutableListBundleFactoryTest.java | 14 ++- .../direct/KeyedPValueTrackingVisitorTest.java | 6 +- .../beam/runners/direct/ParDoEvaluatorTest.java | 5 +- .../runners/direct/SideInputContainerTest.java | 5 +- .../StatefulParDoEvaluatorFactoryTest.java | 7 +- .../runners/direct/StepTransformResultTest.java | 5 +- .../direct/TestStreamEvaluatorFactoryTest.java | 5 +- .../runners/direct/TransformExecutorTest.java | 4 +- .../UnboundedReadEvaluatorFactoryTest.java | 9 +- .../direct/ViewEvaluatorFactoryTest.java | 5 +- .../direct/WatermarkCallbackExecutorTest.java | 5 +- .../runners/direct/WatermarkManagerTest.java | 6 +- .../direct/WindowEvaluatorFactoryTest.java | 5 +- .../direct/WriteWithShardingFactoryTest.java | 14 +-- .../java/org/apache/beam/sdk/PipelineTest.java | 37 +++--- .../apache/beam/sdk/coders/AvroCoderTest.java | 11 +- .../beam/sdk/coders/CoderRegistryTest.java | 6 +- .../beam/sdk/coders/SerializableCoderTest.java | 7 +- .../java/org/apache/beam/sdk/io/AvroIOTest.java | 16 +-- .../io/BoundedReadFromUnboundedSourceTest.java | 6 +- .../beam/sdk/io/CompressedSourceTest.java | 12 +- .../apache/beam/sdk/io/CountingInputTest.java | 12 +- .../apache/beam/sdk/io/CountingSourceTest.java | 13 +- .../apache/beam/sdk/io/FileBasedSourceTest.java | 4 +- .../beam/sdk/io/PubsubUnboundedSinkTest.java | 10 +- .../beam/sdk/io/PubsubUnboundedSourceTest.java | 12 +- .../java/org/apache/beam/sdk/io/TextIOTest.java | 29 +++-- .../java/org/apache/beam/sdk/io/WriteTest.java | 2 +- .../org/apache/beam/sdk/io/XmlSourceTest.java | 10 +- .../sdk/options/ProxyInvocationHandlerTest.java | 5 +- .../sdk/runners/TransformHierarchyTest.java | 6 +- .../beam/sdk/runners/TransformTreeTest.java | 11 +- .../beam/sdk/testing/GatherAllPanesTest.java | 7 +- .../apache/beam/sdk/testing/PAssertTest.java | 32 ++--- .../apache/beam/sdk/testing/TestStreamTest.java | 7 +- .../transforms/ApproximateQuantilesTest.java | 12 +- .../sdk/transforms/ApproximateUniqueTest.java | 6 +- .../beam/sdk/transforms/CombineFnsTest.java | 5 +- .../apache/beam/sdk/transforms/CombineTest.java | 25 +--- .../apache/beam/sdk/transforms/CountTest.java | 13 +- .../apache/beam/sdk/transforms/CreateTest.java | 27 +---- .../beam/sdk/transforms/DistinctTest.java | 12 +- .../apache/beam/sdk/transforms/DoFnTest.java | 4 +- .../beam/sdk/transforms/DoFnTesterTest.java | 6 +- .../apache/beam/sdk/transforms/FilterTest.java | 18 +-- .../sdk/transforms/FlatMapElementsTest.java | 10 +- .../apache/beam/sdk/transforms/FlattenTest.java | 35 +----- .../beam/sdk/transforms/GroupByKeyTest.java | 30 ++--- .../apache/beam/sdk/transforms/KeysTest.java | 9 +- .../apache/beam/sdk/transforms/KvSwapTest.java | 9 +- .../apache/beam/sdk/transforms/LatestTest.java | 12 +- .../beam/sdk/transforms/MapElementsTest.java | 14 +-- .../beam/sdk/transforms/ParDoLifecycleTest.java | 17 +-- .../apache/beam/sdk/transforms/ParDoTest.java | 118 +++++++------------ .../beam/sdk/transforms/PartitionTest.java | 8 +- .../apache/beam/sdk/transforms/RegexTest.java | 25 +--- .../apache/beam/sdk/transforms/SampleTest.java | 34 +++--- .../beam/sdk/transforms/SplittableDoFnTest.java | 12 +- .../org/apache/beam/sdk/transforms/TopTest.java | 15 ++- .../apache/beam/sdk/transforms/ValuesTest.java | 7 +- .../apache/beam/sdk/transforms/ViewTest.java | 84 ++++--------- .../beam/sdk/transforms/WithKeysTest.java | 8 +- .../beam/sdk/transforms/WithTimestampsTest.java | 9 +- .../sdk/transforms/join/CoGroupByKeyTest.java | 11 +- .../sdk/transforms/windowing/WindowTest.java | 22 ++-- .../sdk/transforms/windowing/WindowingTest.java | 11 +- .../org/apache/beam/sdk/util/ReshuffleTest.java | 11 +- .../beam/sdk/values/PCollectionTupleTest.java | 12 +- .../org/apache/beam/sdk/values/PDoneTest.java | 9 +- .../apache/beam/sdk/values/TypedPValueTest.java | 10 +- .../extensions/joinlibrary/InnerJoinTest.java | 9 +- .../joinlibrary/OuterLeftJoinTest.java | 10 +- .../joinlibrary/OuterRightJoinTest.java | 10 +- .../sdk/extensions/sorter/SortValuesTest.java | 7 +- .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 25 ++-- .../sdk/io/gcp/bigtable/BigtableIOTest.java | 13 +- .../org/apache/beam/sdk/io/jdbc/JdbcIOTest.java | 8 +- .../org/apache/beam/sdk/io/jms/JmsIOTest.java | 9 +- .../apache/beam/sdk/io/kafka/KafkaIOTest.java | 25 ++-- .../sdk/io/kinesis/KinesisMockReadTest.java | 7 +- .../beam/sdk/io/kinesis/KinesisReaderIT.java | 6 +- .../sdk/io/mongodb/MongoDBGridFSIOTest.java | 9 +- .../beam/sdk/io/mongodb/MongoDbIOTest.java | 7 +- .../beam/sdk/transforms/CombineJava8Test.java | 8 +- .../beam/sdk/transforms/DistinctJava8Test.java | 5 +- .../beam/sdk/transforms/FilterJava8Test.java | 9 +- .../transforms/FlatMapElementsJava8Test.java | 7 +- .../sdk/transforms/MapElementsJava8Test.java | 9 +- .../beam/sdk/transforms/PartitionJava8Test.java | 7 +- .../beam/sdk/transforms/WithKeysJava8Test.java | 6 +- .../sdk/transforms/WithTimestampsJava8Test.java | 14 ++- 117 files changed, 640 insertions(+), 769 deletions(-) ----------------------------------------------------------------------