You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/12/21 22:49:48 UTC
[14/51] [abbrv] incubator-beam git commit: This closes #1664:
[BEAM-1176] Migrating tests to use TestPipeline as a JUnit rule
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 <kl...@google.com>
Authored: Tue Dec 20 09:55:57 2016 -0800
Committer: Kenneth Knowles <kl...@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(-)
----------------------------------------------------------------------