Remove NeedsRunner category tags from non-core libraries
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0683ac12 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0683ac12 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0683ac12 Branch: refs/heads/master Commit: 0683ac122960a32dd2ef1d83cb2ce82da479105f Parents: 0a17645 Author: Kenneth Knowles <[email protected]> Authored: Wed Mar 29 09:53:19 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Thu Apr 6 13:40:55 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java | 12 ------------ .../java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java | 9 --------- .../test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java | 6 ------ .../java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 6 ------ .../apache/beam/sdk/io/mongodb/MongoDBGridFSIOTest.java | 5 ----- .../org/apache/beam/sdk/io/mongodb/MongoDbIOTest.java | 5 ----- 6 files changed, 43 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/0683ac12/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java index 5ef8b2c..abdc542 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java @@ -118,7 +118,6 @@ import org.apache.beam.sdk.options.ValueProvider.NestedValueProvider; import org.apache.beam.sdk.options.ValueProvider.StaticValueProvider; import org.apache.beam.sdk.testing.CoderProperties; import org.apache.beam.sdk.testing.ExpectedLogs; -import org.apache.beam.sdk.testing.NeedsRunner; import org.apache.beam.sdk.testing.PAssert; import org.apache.beam.sdk.testing.SourceTestUtils; import org.apache.beam.sdk.testing.SourceTestUtils.ExpectedSplitOutcome; @@ -803,7 +802,6 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testBuildSourceWithTableAndFlatten() { BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); @@ -822,7 +820,6 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testBuildSourceWithTableAndFlattenWithoutValidation() { BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); @@ -842,7 +839,6 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testBuildSourceWithTableAndSqlDialect() { BigQueryOptions bqOptions = PipelineOptionsFactory.as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); @@ -861,7 +857,6 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testReadFromTable() throws IOException, InterruptedException { BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); @@ -944,7 +939,6 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testWrite() throws Exception { BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); @@ -976,7 +970,6 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testStreamingWrite() throws Exception { BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); @@ -1105,7 +1098,6 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testStreamingWriteWithWindowFn() throws Exception { BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); @@ -1188,7 +1180,6 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testWriteUnknown() throws Exception { BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); @@ -1221,7 +1212,6 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testWriteFailedJobs() throws Exception { BigQueryOptions bqOptions = TestPipeline.testingPipelineOptions().as(BigQueryOptions.class); bqOptions.setProject("defaultProject"); @@ -2014,7 +2004,6 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testPassThroughThenCleanup() throws Exception { PCollection<Integer> output = p @@ -2031,7 +2020,6 @@ public class BigQueryIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testPassThroughThenCleanupExecuted() throws Exception { p.apply(Create.empty(VarIntCoder.of())) http://git-wip-us.apache.org/repos/asf/beam/blob/0683ac12/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java b/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java index 7bfdd25..ee3369e 100644 --- a/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java +++ b/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java @@ -32,7 +32,6 @@ import org.apache.beam.sdk.io.BoundedSource; import org.apache.beam.sdk.io.hbase.HBaseIO.HBaseSource; import org.apache.beam.sdk.io.range.ByteKey; import org.apache.beam.sdk.io.range.ByteKeyRange; -import org.apache.beam.sdk.testing.NeedsRunner; import org.apache.beam.sdk.testing.PAssert; import org.apache.beam.sdk.testing.TestPipeline; import org.apache.beam.sdk.transforms.Count; @@ -68,7 +67,6 @@ import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Rule; import org.junit.Test; -import org.junit.experimental.categories.Category; import org.junit.rules.ExpectedException; import org.junit.runner.RunWith; import org.junit.runners.JUnit4; @@ -157,7 +155,6 @@ public class HBaseIOTest { /** Tests that when reading from a non-existent table, the read fails. */ @Test - @Category(NeedsRunner.class) public void testReadingFailsTableDoesNotExist() throws Exception { final String table = "TEST-TABLE-INVALID"; // Exception will be thrown by read.validate() when read is applied. @@ -169,7 +166,6 @@ public class HBaseIOTest { /** Tests that when reading from an empty table, the read succeeds. */ @Test - @Category(NeedsRunner.class) public void testReadingEmptyTable() throws Exception { final String table = "TEST-EMPTY-TABLE"; createTable(table); @@ -178,7 +174,6 @@ public class HBaseIOTest { } @Test - @Category(NeedsRunner.class) public void testReading() throws Exception { final String table = "TEST-MANY-ROWS-TABLE"; final int numRows = 1001; @@ -213,7 +208,6 @@ public class HBaseIOTest { /** Tests reading all rows using a filter. */ @Test - @Category(NeedsRunner.class) public void testReadingWithFilter() throws Exception { final String table = "TEST-FILTER-TABLE"; final int numRows = 1001; @@ -234,7 +228,6 @@ public class HBaseIOTest { * range [] and that some properties hold across them. */ @Test - @Category(NeedsRunner.class) public void testReadingWithKeyRange() throws Exception { final String table = "TEST-KEY-RANGE-TABLE"; final int numRows = 1001; @@ -271,7 +264,6 @@ public class HBaseIOTest { /** Tests that a record gets written to the service and messages are logged. */ @Test - @Category(NeedsRunner.class) public void testWriting() throws Exception { final String table = "table"; final String key = "key"; @@ -304,7 +296,6 @@ public class HBaseIOTest { /** Tests that when writing an element fails, the write fails. */ @Test - @Category(NeedsRunner.class) public void testWritingFailsBadElement() throws Exception { final String table = "TEST-TABLE"; final String key = "KEY"; http://git-wip-us.apache.org/repos/asf/beam/blob/0683ac12/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java b/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java index f07247d..8740204 100644 --- a/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java +++ b/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java @@ -44,7 +44,6 @@ import org.apache.activemq.security.SimpleAuthenticationPlugin; import org.apache.activemq.store.memory.MemoryPersistenceAdapter; import org.apache.beam.sdk.options.PipelineOptions; import org.apache.beam.sdk.options.PipelineOptionsFactory; -import org.apache.beam.sdk.testing.NeedsRunner; import org.apache.beam.sdk.testing.PAssert; import org.apache.beam.sdk.testing.TestPipeline; import org.apache.beam.sdk.transforms.Count; @@ -54,7 +53,6 @@ import org.junit.After; import org.junit.Before; import org.junit.Rule; import org.junit.Test; -import org.junit.experimental.categories.Category; import org.junit.runner.RunWith; import org.junit.runners.JUnit4; @@ -122,7 +120,6 @@ public class JmsIOTest { } @Test - @Category(NeedsRunner.class) public void testAuthenticationRequired() { pipeline.apply( JmsIO.read() @@ -133,7 +130,6 @@ public class JmsIOTest { } @Test - @Category(NeedsRunner.class) public void testAuthenticationWithBadPassword() { pipeline.apply( JmsIO.read() @@ -147,7 +143,6 @@ public class JmsIOTest { } @Test - @Category(NeedsRunner.class) public void testReadMessages() throws Exception { // produce message @@ -187,7 +182,6 @@ public class JmsIOTest { } @Test - @Category(NeedsRunner.class) public void testWriteMessage() throws Exception { ArrayList<String> data = new ArrayList<>(); http://git-wip-us.apache.org/repos/asf/beam/blob/0683ac12/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java b/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java index 7e77512..ecbc71d 100644 --- a/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java +++ b/sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java @@ -48,7 +48,6 @@ import org.apache.beam.sdk.io.Read; import org.apache.beam.sdk.io.UnboundedSource; import org.apache.beam.sdk.io.UnboundedSource.UnboundedReader; import org.apache.beam.sdk.options.PipelineOptionsFactory; -import org.apache.beam.sdk.testing.NeedsRunner; import org.apache.beam.sdk.testing.PAssert; import org.apache.beam.sdk.testing.TestPipeline; import org.apache.beam.sdk.transforms.Count; @@ -81,7 +80,6 @@ import org.hamcrest.collection.IsIterableContainingInAnyOrder; import org.joda.time.Instant; import org.junit.Rule; import org.junit.Test; -import org.junit.experimental.categories.Category; import org.junit.rules.ExpectedException; import org.junit.runner.RunWith; import org.junit.runners.JUnit4; @@ -281,7 +279,6 @@ public class KafkaIOTest { } @Test - @Category(NeedsRunner.class) public void testUnboundedSource() { int numElements = 1000; @@ -319,7 +316,6 @@ public class KafkaIOTest { } @Test - @Category(NeedsRunner.class) public void testUnboundedSourceWithExplicitPartitions() { int numElements = 1000; @@ -358,7 +354,6 @@ public class KafkaIOTest { } @Test - @Category(NeedsRunner.class) public void testUnboundedSourceTimestamps() { int numElements = 1000; @@ -386,7 +381,6 @@ public class KafkaIOTest { } @Test - @Category(NeedsRunner.class) public void testUnboundedSourceSplits() throws Exception { int numElements = 1000; http://git-wip-us.apache.org/repos/asf/beam/blob/0683ac12/sdks/java/io/mongodb/src/test/java/org/apache/beam/sdk/io/mongodb/MongoDBGridFSIOTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/mongodb/src/test/java/org/apache/beam/sdk/io/mongodb/MongoDBGridFSIOTest.java b/sdks/java/io/mongodb/src/test/java/org/apache/beam/sdk/io/mongodb/MongoDBGridFSIOTest.java index 994be87..71718e3 100644 --- a/sdks/java/io/mongodb/src/test/java/org/apache/beam/sdk/io/mongodb/MongoDBGridFSIOTest.java +++ b/sdks/java/io/mongodb/src/test/java/org/apache/beam/sdk/io/mongodb/MongoDBGridFSIOTest.java @@ -63,7 +63,6 @@ import org.apache.beam.sdk.io.mongodb.MongoDbGridFSIO.Read.BoundedGridFSSource; import org.apache.beam.sdk.io.mongodb.MongoDbGridFSIO.WriteFn; import org.apache.beam.sdk.options.PipelineOptions; import org.apache.beam.sdk.options.PipelineOptionsFactory; -import org.apache.beam.sdk.testing.NeedsRunner; import org.apache.beam.sdk.testing.PAssert; import org.apache.beam.sdk.testing.SourceTestUtils; import org.apache.beam.sdk.testing.TestPipeline; @@ -80,7 +79,6 @@ import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Rule; import org.junit.Test; -import org.junit.experimental.categories.Category; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -183,7 +181,6 @@ public class MongoDBGridFSIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testFullRead() throws Exception { PCollection<String> output = pipeline.apply( @@ -212,7 +209,6 @@ public class MongoDBGridFSIOTest implements Serializable { @Test - @Category(NeedsRunner.class) public void testReadWithParser() throws Exception { PCollection<KV<String, Integer>> output = pipeline.apply( @@ -295,7 +291,6 @@ public class MongoDBGridFSIOTest implements Serializable { @Test - @Category(NeedsRunner.class) public void testWriteMessage() throws Exception { ArrayList<String> data = new ArrayList<>(100); http://git-wip-us.apache.org/repos/asf/beam/blob/0683ac12/sdks/java/io/mongodb/src/test/java/org/apache/beam/sdk/io/mongodb/MongoDbIOTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/mongodb/src/test/java/org/apache/beam/sdk/io/mongodb/MongoDbIOTest.java b/sdks/java/io/mongodb/src/test/java/org/apache/beam/sdk/io/mongodb/MongoDbIOTest.java index e7ff712..c36b7c8 100644 --- a/sdks/java/io/mongodb/src/test/java/org/apache/beam/sdk/io/mongodb/MongoDbIOTest.java +++ b/sdks/java/io/mongodb/src/test/java/org/apache/beam/sdk/io/mongodb/MongoDbIOTest.java @@ -41,7 +41,6 @@ import java.io.Serializable; import java.net.ServerSocket; import java.util.ArrayList; -import org.apache.beam.sdk.testing.NeedsRunner; import org.apache.beam.sdk.testing.PAssert; import org.apache.beam.sdk.testing.TestPipeline; import org.apache.beam.sdk.transforms.Count; @@ -59,7 +58,6 @@ import org.junit.Before; import org.junit.BeforeClass; import org.junit.Rule; import org.junit.Test; -import org.junit.experimental.categories.Category; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -145,7 +143,6 @@ public class MongoDbIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testFullRead() throws Exception { PCollection<Document> output = pipeline.apply( @@ -178,7 +175,6 @@ public class MongoDbIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testReadWithFilter() throws Exception { PCollection<Document> output = pipeline.apply( @@ -195,7 +191,6 @@ public class MongoDbIOTest implements Serializable { } @Test - @Category(NeedsRunner.class) public void testWrite() throws Exception { ArrayList<Document> data = new ArrayList<>();
