Update tags

apache · Dec 29, 2021 · d9f166e · d9f166e
1 parent 1c6c3f6
commit d9f166e
Show file tree

Hide file tree

Showing 19 changed files with 10 additions and 89 deletions.
diff --git a/examples/java/src/test/java/org/apache/beam/examples/complete/TfIdfTest.java b/examples/java/src/test/java/org/apache/beam/examples/complete/TfIdfTest.java
@@ -24,6 +24,7 @@
 //   pipeline_options:
 //   categories:
 //     - Side Input
+//     - Flatten
 
 import java.net.URI;
 import java.util.Arrays;

diff --git a/examples/java/src/test/java/org/apache/beam/examples/complete/game/GameStatsTest.java b/examples/java/src/test/java/org/apache/beam/examples/complete/game/GameStatsTest.java
@@ -24,6 +24,7 @@
 //   pipeline_options:
 //   categories:
 //     - Testing
+//     - Filtering
 
 import java.io.Serializable;
 import java.util.Arrays;

diff --git a/...java/src/test/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaToPubsubTest.java b/...java/src/test/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaToPubsubTest.java
@@ -17,14 +17,6 @@
  */
 package org.apache.beam.examples.complete.kafkatopubsub;
 
-// beam-playground:
-//   name: KafkaToPubsubTest
-//   description: Unit-test for the KafkaToPubsub example.
-//   multifile: false
-//   pipeline_options:
-//   categories:
-//     - Streaming
-
 import static org.apache.beam.examples.complete.kafkatopubsub.KafkaPubsubConstants.PASSWORD;
 import static org.apache.beam.examples.complete.kafkatopubsub.KafkaPubsubConstants.USERNAME;
 import static org.apache.beam.examples.complete.kafkatopubsub.kafka.consumer.Utils.getKafkaCredentialsFromVault;

diff --git a/examples/java/src/test/java/org/apache/beam/examples/cookbook/DistinctExampleTest.java b/examples/java/src/test/java/org/apache/beam/examples/cookbook/DistinctExampleTest.java
@@ -23,8 +23,8 @@
 //   multifile: false
 //   pipeline_options:
 //   categories:
-//     - IO
-//     - Options
+//     - Core Transforms
+//     - Filtering
 
 import java.util.Arrays;
 import java.util.List;

diff --git a/sdks/go/pkg/beam/core/util/symtab/symtab_test.go b/sdks/go/pkg/beam/core/util/symtab/symtab_test.go
@@ -15,14 +15,6 @@
 
 package symtab
 
-// beam-playground:
-//   name: SymtabTest
-//   description: Unit-test for the Symtab example.
-//   multifile: false
-//   pipeline_options:
-//   categories:
-//     - Side Input
-
 import (
 	"io/ioutil"
 	"os"

diff --git a/sdks/go/pkg/beam/partition_test.go b/sdks/go/pkg/beam/partition_test.go
@@ -21,7 +21,7 @@ package beam_test
 //   multifile: false
 //   pipeline_options:
 //   categories:
-//     - Testing
+//     - Core Transforms
 
 import (
 	"testing"

diff --git a/sdks/go/pkg/beam/transforms/filter/distinct_test.go b/sdks/go/pkg/beam/transforms/filter/distinct_test.go
@@ -22,6 +22,7 @@ package filter_test
 //   pipeline_options:
 //   categories:
 //     - Filtering
+//     - Core Transforms
 
 import (
 	"testing"

diff --git a/sdks/go/test/integration/integration.go b/sdks/go/test/integration/integration.go
@@ -34,16 +34,6 @@
 // environment setup, or by calling gradle commands in :sdks:go:test.
 package integration
 
-// beam-playground:
-//   name: CheckFiltersTest
-//   description: Unit-test checks if an integration test is filtered to be skipped, either
-//     because the intended runner does not support it, or the test is sickbayed.
-//   multifile: false
-//   pipeline_options:
-//   categories:
-//     - Filtering
-//     - Testing
-
 import (
 	"fmt"
 	"regexp"

diff --git a/sdks/go/test/integration/synthetic/synthetic_test.go b/sdks/go/test/integration/synthetic/synthetic_test.go
@@ -15,14 +15,6 @@
 
 package synthetic
 
-// beam-playground:
-//   name: SyntheticTest
-//   description: Unit-test for the Synthetic example.
-//   multifile: false
-//   pipeline_options:
-//   categories:
-//	   - Testing
-
 import (
 	"testing"
 

diff --git a/sdks/go/test/integration/xlang/xlang_test.go b/sdks/go/test/integration/xlang/xlang_test.go
@@ -15,15 +15,6 @@
 
 package xlang
 
-// beam-playground:
-//   name: XLangTest
-//   description: Unit-test for the XLang example.
-//   multifile: false
-//   pipeline_options:
-//   categories:
-//     - Combiners
-//	   - Testing
-
 import (
 	"fmt"
 	"reflect"

diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/FileBasedSourceTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/FileBasedSourceTest.java
@@ -17,14 +17,6 @@
  */
 package org.apache.beam.sdk.io;
 
-// beam-playground:
-//   name: FileBasedSourceTest
-//   description: Unit-test for the FileBasedSource example.
-//   multifile: false
-//   pipeline_options:
-//   categories:
-//     - IO
-
 import static org.apache.beam.sdk.testing.SourceTestUtils.assertSplitAtFractionExhaustive;
 import static org.apache.beam.sdk.testing.SourceTestUtils.assertSplitAtFractionFails;
 import static org.apache.beam.sdk.testing.SourceTestUtils.assertSplitAtFractionSucceedsAndConsistent;

diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/transforms/ConvertTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/transforms/ConvertTest.java
@@ -17,14 +17,6 @@
  */
 package org.apache.beam.sdk.schemas.transforms;
 
-// beam-playground:
-//   name: ConvertTest
-//   description: Unit-test for the Convert example.
-//   multifile: false
-//   pipeline_options:
-//   categories:
-//     - Schemas
-
 import java.util.Arrays;
 import java.util.Map;
 import java.util.Objects;

diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/testing/TestStreamTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/testing/TestStreamTest.java
@@ -23,7 +23,7 @@
 //   multifile: false
 //   pipeline_options:
 //   categories:
-//     - Testing
+//     - Streaming
 
 import static org.apache.beam.sdk.transforms.windowing.Window.into;
 import static org.hamcrest.MatcherAssert.assertThat;

diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/windowing/WindowingTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/windowing/WindowingTest.java
@@ -17,15 +17,6 @@
  */
 package org.apache.beam.sdk.transforms.windowing;
 
-// beam-playground:
-//   name: WindowingTest
-//   description: Unit-test for the Windowing kata.
-//   multifile: false
-//   pipeline_options:
-//   categories:
-//     - Windowing
-//     - Streaming
-
 import java.io.File;
 import java.io.FileOutputStream;
 import java.io.PrintStream;

diff --git a/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py b/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py
@@ -26,6 +26,7 @@
 #   pipeline_options:
 #   categories:
 #     - Streaming
+#     - IO
 
 import logging
 import unittest

diff --git a/sdks/python/apache_beam/examples/wordcount_minimal_test.py b/sdks/python/apache_beam/examples/wordcount_minimal_test.py
@@ -26,6 +26,7 @@
 #   pipeline_options:
 #   categories:
 #     - IO
+#     - Combiners
 
 import collections
 import logging

diff --git a/sdks/python/apache_beam/examples/wordcount_test.py b/sdks/python/apache_beam/examples/wordcount_test.py
@@ -27,6 +27,7 @@
 #   pipeline_options:
 #   categories:
 #     - IO
+#     - Combiners
 
 import collections
 import logging

diff --git a/sdks/python/apache_beam/io/filesystemio_test.py b/sdks/python/apache_beam/io/filesystemio_test.py
@@ -19,14 +19,6 @@
 
 # pytype: skip-file
 
-# beam-playground:
-#   name: FileSystemIOTest
-#   description: Unit-test for the FileSystemIO example.
-#   multifile: false
-#   pipeline_options:
-#   categories:
-#     - IO
-
 import io
 import logging
 import multiprocessing

diff --git a/sdks/python/apache_beam/transforms/window_test.py b/sdks/python/apache_beam/transforms/window_test.py
@@ -18,15 +18,6 @@
 """Unit tests for the windowing classes."""
 # pytype: skip-file
 
-# beam-playground:
-#   name: MetricTest
-#   description: Unit-test for the Window example.
-#   multifile: false
-#   pipeline_options:
-#   categories:
-#     - Core Transforms
-#	  - Windowing
-
 import unittest
 
 import apache_beam as beam