apache · kennknowles · Nov 5, 2020 · Oct 23, 2020 · Oct 23, 2020 · kennknowles
diff --git a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy
@@ -91,9 +91,6 @@ class BeamModulePlugin implements Plugin<Project> {
     /** Controls whether the checker framework plugin is enabled and configured. */
     boolean enableChecker = true
 
-    /** Controls whether legacy rawtype usage is allowed. */
-    boolean ignoreRawtypeErrors = false
-
     /** Controls whether the dependency analysis plugin is enabled. */
     boolean enableStrictDependencies = false
 
@@ -719,10 +716,6 @@ class BeamModulePlugin implements Plugin<Project> {
         'varargs',
       ]
 
-      if (configuration.ignoreRawtypeErrors) {
-        defaultLintSuppressions.add("rawtypes")
-      }
-
       project.tasks.withType(JavaCompile) {
         options.encoding = "UTF-8"
         // As we want to add '-Xlint:-deprecation' we intentionally remove '-Xlint:deprecation' from compilerArgs here,

diff --git a/examples/java/build.gradle b/examples/java/build.gradle
@@ -22,7 +22,6 @@ plugins { id 'org.apache.beam.module' }
 applyJavaNature(
   exportJavadoc: false,
   enableChecker: false,
-  ignoreRawtypeErrors: true,
   automaticModuleName: 'org.apache.beam.examples')
 provideIntegrationTestingDependencies()
 enableJavaPerformanceTesting()

diff --git a/examples/java/src/main/java/org/apache/beam/examples/common/ExampleUtils.java b/examples/java/src/main/java/org/apache/beam/examples/common/ExampleUtils.java
@@ -62,7 +62,9 @@
  *
  * <p>It is used to run Beam examples.
  */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class ExampleUtils {
 
   private static final int SC_NOT_FOUND = 404;

diff --git a/examples/java/src/main/java/org/apache/beam/examples/complete/AutoComplete.java b/examples/java/src/main/java/org/apache/beam/examples/complete/AutoComplete.java
@@ -95,7 +95,9 @@
  * <p>This will update the Cloud Datastore every 10 seconds based on the last 30 minutes of data
  * received.
  */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class AutoComplete {
 
   /**

diff --git a/examples/java/src/main/java/org/apache/beam/examples/complete/TrafficMaxLaneFlow.java b/examples/java/src/main/java/org/apache/beam/examples/complete/TrafficMaxLaneFlow.java
@@ -73,7 +73,9 @@
  * <p>The example will try to cancel the pipelines on the signal to terminate the process (CTRL-C)
  * and then exits.
  */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class TrafficMaxLaneFlow {
 
   static final int WINDOW_DURATION = 60; // Default sliding window duration in minutes

diff --git a/examples/java/src/main/java/org/apache/beam/examples/complete/TrafficRoutes.java b/examples/java/src/main/java/org/apache/beam/examples/complete/TrafficRoutes.java
@@ -77,7 +77,9 @@
  * <p>The example will try to cancel the pipelines on the signal to terminate the process (CTRL-C)
  * and then exits.
  */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class TrafficRoutes {
 
   // Instantiate some small predefined San Diego routes to analyze

diff --git a/examples/java/src/main/java/org/apache/beam/examples/complete/game/StatefulTeamScore.java b/examples/java/src/main/java/org/apache/beam/examples/complete/game/StatefulTeamScore.java
@@ -76,7 +76,9 @@
  * <p>The BigQuery dataset you specify must already exist. The PubSub topic you specify should be
  * the same topic to which the Injector is publishing.
  */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class StatefulTeamScore extends LeaderBoard {
 
   /** Options supported by {@link StatefulTeamScore}. */

diff --git a/examples/java/src/main/java/org/apache/beam/examples/complete/game/UserScore.java b/examples/java/src/main/java/org/apache/beam/examples/complete/game/UserScore.java
@@ -70,7 +70,9 @@
  * value for example batch data file, or use {@code injector.Injector} to generate your own batch
  * data.
  */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class UserScore {
 
   /** Class to hold info about a game event. */

diff --git a/examples/java/src/main/java/org/apache/beam/examples/complete/game/injector/Injector.java b/examples/java/src/main/java/org/apache/beam/examples/complete/game/injector/Injector.java
@@ -75,7 +75,9 @@
  * Injector <project-name> none <filename>
  * }</pre>
  */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 class Injector {
   private static Pubsub pubsub;
   private static Random random = new Random();

diff --git a/...ples/java/src/main/java/org/apache/beam/examples/complete/game/utils/WriteToBigQuery.java b/...ples/java/src/main/java/org/apache/beam/examples/complete/game/utils/WriteToBigQuery.java
@@ -39,7 +39,9 @@
  * Generate, format, and write BigQuery table row information. Use provided information about the
  * field names and types, as well as lambda functions that describe how to generate their values.
  */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class WriteToBigQuery<InputT> extends PTransform<PCollection<InputT>, PDone> {
 
   protected String projectId;

diff --git a/examples/java/src/main/java/org/apache/beam/examples/complete/game/utils/WriteToText.java b/examples/java/src/main/java/org/apache/beam/examples/complete/game/utils/WriteToText.java
@@ -47,7 +47,9 @@
  * Generate, format, and write rows. Use provided information about the field names and types, as
  * well as lambda functions that describe how to generate their values.
  */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class WriteToText<InputT> extends PTransform<PCollection<InputT>, PDone> {
 
   private static final DateTimeFormatter formatter =

diff --git a/examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java b/examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java
@@ -121,7 +121,9 @@
  * <p>The example will try to cancel the pipelines on the signal to terminate the process (CTRL-C)
  * and then exits.
  */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class TriggerExample {
   // Numeric value of fixed window duration, in minutes
   public static final int WINDOW_DURATION = 30;

diff --git a/examples/java/src/main/java/org/apache/beam/examples/snippets/Snippets.java b/examples/java/src/main/java/org/apache/beam/examples/snippets/Snippets.java
@@ -116,7 +116,10 @@
 import org.slf4j.LoggerFactory;
 
 /** Code snippets used in webdocs. */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class Snippets {
 
   @DefaultCoder(AvroCoder.class)

diff --git a/...ain/java/org/apache/beam/examples/snippets/transforms/io/gcp/bigquery/BigQueryMyData.java b/...ain/java/org/apache/beam/examples/snippets/transforms/io/gcp/bigquery/BigQueryMyData.java
@@ -33,7 +33,9 @@
 import org.apache.beam.sdk.coders.AvroCoder;
 import org.apache.beam.sdk.coders.DefaultCoder;
 
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 class BigQueryMyData {
 
   @SuppressFBWarnings("URF_UNREAD_FIELD")

diff --git a/...a/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessCommandLineArgs.java b/...a/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessCommandLineArgs.java
@@ -21,7 +21,9 @@
 import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.Lists;
 
 /** Parameters to the sub-process, has tuple of ordinal position and the value. */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class SubProcessCommandLineArgs {
 
   // Parameters to pass to the sub-process

diff --git a/examples/java/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessKernel.java b/examples/java/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessKernel.java
@@ -33,7 +33,9 @@
 /**
  * This is the process kernel which deals with exec of the subprocess. It also deals with all I/O.
  */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class SubProcessKernel {
 
   private static final Logger LOG = LoggerFactory.getLogger(SubProcessKernel.class);

diff --git a/examples/java/src/main/java/org/apache/beam/examples/subprocess/utils/ExecutableFile.java b/examples/java/src/main/java/org/apache/beam/examples/subprocess/utils/ExecutableFile.java
@@ -25,7 +25,9 @@
 
 /** Contains the configuration for the external library. */
 @DefaultCoder(AvroCoder.class)
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class ExecutableFile {
 
   String fileName;

diff --git a/examples/java/src/main/java/org/apache/beam/examples/subprocess/utils/FileUtils.java b/examples/java/src/main/java/org/apache/beam/examples/subprocess/utils/FileUtils.java
@@ -36,7 +36,9 @@
 import org.slf4j.LoggerFactory;
 
 /** Utilities for dealing with movement of files from object stores and workers. */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class FileUtils {
 
   private static final Logger LOG = LoggerFactory.getLogger(FileUtils.class);

diff --git a/examples/java/src/test/java/org/apache/beam/examples/WindowedWordCountIT.java b/examples/java/src/test/java/org/apache/beam/examples/WindowedWordCountIT.java
@@ -62,7 +62,9 @@
 
 /** End-to-end integration test of {@link WindowedWordCount}. */
 @RunWith(JUnit4.class)
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class WindowedWordCountIT {
 
   @Rule public TestName testName = new TestName();

diff --git a/examples/java/src/test/java/org/apache/beam/examples/complete/TrafficMaxLaneFlowIT.java b/examples/java/src/test/java/org/apache/beam/examples/complete/TrafficMaxLaneFlowIT.java
@@ -42,7 +42,9 @@
 
 /** End-to-end tests of TrafficMaxLaneFlowIT. */
 @RunWith(JUnit4.class)
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class TrafficMaxLaneFlowIT {
   private static final Logger LOG = LoggerFactory.getLogger(TrafficMaxLaneFlowIT.class);
   private TrafficMaxLaneFlowOptions options;

diff --git a/examples/java/src/test/java/org/apache/beam/examples/complete/TrafficRoutesIT.java b/examples/java/src/test/java/org/apache/beam/examples/complete/TrafficRoutesIT.java
@@ -42,7 +42,9 @@
 
 /** End-to-end tests of TrafficRoutes. */
 @RunWith(JUnit4.class)
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class TrafficRoutesIT {
   private static final Logger LOG = LoggerFactory.getLogger(TrafficRoutesIT.class);
   private TrafficRoutesOptions options;

diff --git a/examples/java/src/test/java/org/apache/beam/examples/complete/game/HourlyTeamScoreTest.java b/examples/java/src/test/java/org/apache/beam/examples/complete/game/HourlyTeamScoreTest.java
@@ -47,6 +47,9 @@
  * ideas: https://beam.apache.org/documentation/pipelines/test-your-pipeline/
  */
 @RunWith(JUnit4.class)
+@SuppressWarnings({
+  "rawtypes" // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
+})
 public class HourlyTeamScoreTest implements Serializable {
 
   static final String[] GAME_EVENTS_ARRAY =

diff --git a/runners/core-construction-java/build.gradle b/runners/core-construction-java/build.gradle
@@ -19,7 +19,6 @@
 plugins { id 'org.apache.beam.module' }
 applyJavaNature(
   enableChecker: false,
-  ignoreRawtypeErrors: true,
   automaticModuleName: 'org.apache.beam.runners.core.construction')
 
 description = "Apache Beam :: Runners :: Core Construction Java"

diff --git a/...va/src/main/java/org/apache/beam/runners/core/construction/AvroGenericCoderRegistrar.java b/...va/src/main/java/org/apache/beam/runners/core/construction/AvroGenericCoderRegistrar.java
@@ -25,6 +25,9 @@
 
 /** Coder registrar for AvroGenericCoder. */
 @AutoService(CoderTranslatorRegistrar.class)
+@SuppressWarnings({
+  "rawtypes" // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
+})
 public class AvroGenericCoderRegistrar implements CoderTranslatorRegistrar {
   public static final String AVRO_CODER_URN = "beam:coder:avro:generic:v1";
 

diff --git a/...uction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslation.java b/...uction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslation.java
@@ -35,7 +35,10 @@
 import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableMap;
 
 /** Converts to and from Beam Runner API representations of {@link Coder Coders}. */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class CoderTranslation {
 
   /**

diff --git a/...ava/src/main/java/org/apache/beam/runners/core/construction/CoderTranslatorRegistrar.java b/...ava/src/main/java/org/apache/beam/runners/core/construction/CoderTranslatorRegistrar.java
@@ -21,6 +21,9 @@
 import org.apache.beam.sdk.coders.Coder;
 
 /** A registrar of {@link Coder} URNs to the associated {@link CoderTranslator}. */
+@SuppressWarnings({
+  "rawtypes" // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
+})
 public interface CoderTranslatorRegistrar {
   /**
    * Returns a mapping of coder classes to the URN representing that coder.

diff --git a/...tion-java/src/main/java/org/apache/beam/runners/core/construction/CombineTranslation.java b/...tion-java/src/main/java/org/apache/beam/runners/core/construction/CombineTranslation.java
@@ -48,6 +48,9 @@
  * Methods for translating between {@link Combine} {@link PTransform PTransforms} and {@link
  * RunnerApi.CombinePayload} protos.
  */
+@SuppressWarnings({
+  "rawtypes" // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
+})
 public class CombineTranslation {
 
   static final String JAVA_SERIALIZED_COMBINE_FN_URN = "beam:combinefn:javasdk:v1";

diff --git a/...main/java/org/apache/beam/runners/core/construction/CreatePCollectionViewTranslation.java b/...main/java/org/apache/beam/runners/core/construction/CreatePCollectionViewTranslation.java
@@ -44,6 +44,9 @@
  *     dedicated runners-core-construction auxiliary class
  */
 @Deprecated
+@SuppressWarnings({
+  "rawtypes" // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
+})
 public class CreatePCollectionViewTranslation {
 
   /**

diff --git a/...java/src/main/java/org/apache/beam/runners/core/construction/DefaultArtifactResolver.java b/...java/src/main/java/org/apache/beam/runners/core/construction/DefaultArtifactResolver.java
@@ -34,7 +34,9 @@
  * they registered i.e. the function registered later overrides the earlier one if they resolve the
  * same artifact.
  */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class DefaultArtifactResolver implements ArtifactResolver {
   public static final ArtifactResolver INSTANCE = new DefaultArtifactResolver();
 

diff --git a/...-java/src/main/java/org/apache/beam/runners/core/construction/DisplayDataTranslation.java b/...-java/src/main/java/org/apache/beam/runners/core/construction/DisplayDataTranslation.java
@@ -30,7 +30,9 @@
 import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableMap;
 
 /** Utilities for going to/from DisplayData protos. */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class DisplayDataTranslation {
   public static final String LABELLED_STRING = "beam:display_data:labelled_string:v1";
 

diff --git a/...nstruction-java/src/main/java/org/apache/beam/runners/core/construction/Environments.java b/...nstruction-java/src/main/java/org/apache/beam/runners/core/construction/Environments.java
@@ -60,7 +60,9 @@
 import org.slf4j.LoggerFactory;
 
 /** Utilities for interacting with portability {@link Environment environments}. */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class Environments {
   private static final Logger LOG = LoggerFactory.getLogger(Environments.class);
 

diff --git a/...e-construction-java/src/main/java/org/apache/beam/runners/core/construction/External.java b/...e-construction-java/src/main/java/org/apache/beam/runners/core/construction/External.java
@@ -68,7 +68,10 @@
  * high-level wrapper classes rather than this one.
  */
 @Experimental(Kind.PORTABILITY)
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public class External {
   private static final String EXPANDED_TRANSFORM_BASE_NAME = "external";
   private static final String IMPULSE_PREFIX = "IMPULSE";

diff --git a/...ion-java/src/main/java/org/apache/beam/runners/core/construction/ExternalTranslation.java b/...ion-java/src/main/java/org/apache/beam/runners/core/construction/ExternalTranslation.java
@@ -32,6 +32,9 @@
 import org.checkerframework.checker.nullness.qual.Nullable;
 
 /** Translating External transforms to proto. */
+@SuppressWarnings({
+  "rawtypes" // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
+})
 public class ExternalTranslation {
   public static final String EXTERNAL_TRANSFORM_URN = "beam:transform:external:v1";
 

diff --git a/...ction-java/src/main/java/org/apache/beam/runners/core/construction/FlattenTranslator.java b/...ction-java/src/main/java/org/apache/beam/runners/core/construction/FlattenTranslator.java
@@ -31,6 +31,9 @@
 /**
  * Utility methods for translating a {@link Assign} to and from {@link RunnerApi} representations.
  */
+@SuppressWarnings({
+  "rawtypes" // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
+})
 public class FlattenTranslator implements TransformPayloadTranslator<Flatten.PCollections<?>> {
 
   public static TransformPayloadTranslator create() {

diff --git a/...on-java/src/main/java/org/apache/beam/runners/core/construction/ForwardingPTransform.java b/...on-java/src/main/java/org/apache/beam/runners/core/construction/ForwardingPTransform.java
@@ -33,7 +33,10 @@
  * delegate transform but with overridden methods. Implementors are required to implement {@link
  * #delegate()}, which returns the object to forward calls to, and {@link #expand(PInput)}.
  */
-@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+@SuppressWarnings({
+  "rawtypes", // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
+  "nullness" // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
+})
 public abstract class ForwardingPTransform<InputT extends PInput, OutputT extends POutput>
     extends PTransform<InputT, OutputT> {
   protected abstract PTransform<InputT, OutputT> delegate();

diff --git a/...n-java/src/main/java/org/apache/beam/runners/core/construction/GroupByKeyTranslation.java b/...n-java/src/main/java/org/apache/beam/runners/core/construction/GroupByKeyTranslation.java
@@ -31,6 +31,9 @@
  * Utility methods for translating a {@link GroupByKey} to and from {@link RunnerApi}
  * representations.
  */
+@SuppressWarnings({
+  "rawtypes" // TODO(https://issues.apache.org/jira/browse/BEAM-10556)
+})
 public class GroupByKeyTranslation {
 
   static class GroupByKeyTranslator implements TransformPayloadTranslator<GroupByKey<?, ?>> {