[BEAM-10402] Suppress nullness errors in classes that need it

examples/java/src/main/java/org/apache/beam/examples/common/ExampleUtils.java

@@ -62,6 +62,7 @@
  *
  * <p>It is used to run Beam examples.
  */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class ExampleUtils {
 
   private static final int SC_NOT_FOUND = 404;

examples/java/src/main/java/org/apache/beam/examples/complete/AutoComplete.java

@@ -95,6 +95,7 @@
  * <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)
 public class AutoComplete {
 
   /**

examples/java/src/main/java/org/apache/beam/examples/complete/TrafficMaxLaneFlow.java

@@ -73,6 +73,7 @@
  * <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)
 public class TrafficMaxLaneFlow {
 
   static final int WINDOW_DURATION = 60; // Default sliding window duration in minutes

examples/java/src/main/java/org/apache/beam/examples/complete/TrafficRoutes.java

@@ -77,6 +77,7 @@
  * <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)
 public class TrafficRoutes {
 
   // Instantiate some small predefined San Diego routes to analyze

examples/java/src/main/java/org/apache/beam/examples/complete/game/StatefulTeamScore.java

@@ -76,6 +76,7 @@
  * <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)
 public class StatefulTeamScore extends LeaderBoard {
 
   /** Options supported by {@link StatefulTeamScore}. */

examples/java/src/main/java/org/apache/beam/examples/complete/game/UserScore.java

@@ -70,6 +70,7 @@
  * 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)
 public class UserScore {
 
   /** Class to hold info about a game event. */

examples/java/src/main/java/org/apache/beam/examples/complete/game/injector/Injector.java

@@ -75,6 +75,7 @@
  * Injector <project-name> none <filename>
  * }</pre>
  */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 class Injector {
   private static Pubsub pubsub;
   private static Random random = new Random();

examples/java/src/main/java/org/apache/beam/examples/complete/game/utils/WriteToBigQuery.java

@@ -39,6 +39,7 @@
  * 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)
 public class WriteToBigQuery<InputT> extends PTransform<PCollection<InputT>, PDone> {
 
   protected String projectId;

examples/java/src/main/java/org/apache/beam/examples/complete/game/utils/WriteToText.java

@@ -47,6 +47,7 @@
  * 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)
 public class WriteToText<InputT> extends PTransform<PCollection<InputT>, PDone> {
 
   private static final DateTimeFormatter formatter =

examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java

@@ -121,6 +121,7 @@
  * <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)
 public class TriggerExample {
   // Numeric value of fixed window duration, in minutes
   public static final int WINDOW_DURATION = 30;

examples/java/src/main/java/org/apache/beam/examples/snippets/Snippets.java

@@ -116,6 +116,7 @@
 import org.slf4j.LoggerFactory;
 
 /** Code snippets used in webdocs. */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class Snippets {
 
   @DefaultCoder(AvroCoder.class)

examples/java/src/main/java/org/apache/beam/examples/snippets/transforms/io/gcp/bigquery/BigQueryMyData.java

@@ -33,6 +33,7 @@
 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)
 class BigQueryMyData {
 
   @SuppressFBWarnings("URF_UNREAD_FIELD")

examples/java/src/main/java/org/apache/beam/examples/subprocess/configuration/SubProcessConfiguration.java

@@ -23,7 +23,7 @@
  * Configuration file used to setup the Process kernel for execution of the external library Values
  * are copied from the Options to all them to be Serializable.
  */
-@SuppressWarnings("serial")
+@SuppressWarnings({"serial", "nullness"}) // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class SubProcessConfiguration implements Serializable {
 
   // Source GCS directory where the C++ library is located gs://bucket/tests

examples/java/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessCommandLineArgs.java

@@ -21,6 +21,7 @@
 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)
 public class SubProcessCommandLineArgs {
 
   // Parameters to pass to the sub-process

examples/java/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessKernel.java

@@ -33,6 +33,7 @@
 /**
  * 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)
 public class SubProcessKernel {
 
   private static final Logger LOG = LoggerFactory.getLogger(SubProcessKernel.class);

examples/java/src/main/java/org/apache/beam/examples/subprocess/utils/ExecutableFile.java

@@ -25,6 +25,7 @@
 
 /** Contains the configuration for the external library. */
 @DefaultCoder(AvroCoder.class)
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class ExecutableFile {
 
   String fileName;

examples/java/src/main/java/org/apache/beam/examples/subprocess/utils/FileUtils.java

@@ -36,6 +36,7 @@
 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)
 public class FileUtils {
 
   private static final Logger LOG = LoggerFactory.getLogger(FileUtils.class);

examples/java/src/test/java/org/apache/beam/examples/WindowedWordCountIT.java

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

examples/java/src/test/java/org/apache/beam/examples/complete/TrafficMaxLaneFlowIT.java

@@ -42,6 +42,7 @@
 
 /** End-to-end tests of TrafficMaxLaneFlowIT. */
 @RunWith(JUnit4.class)
+@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;

examples/java/src/test/java/org/apache/beam/examples/complete/TrafficRoutesIT.java

@@ -42,6 +42,7 @@
 
 /** End-to-end tests of TrafficRoutes. */
 @RunWith(JUnit4.class)
+@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;

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslation.java

@@ -35,6 +35,7 @@
 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)
 public class CoderTranslation {
 
   /**

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/DefaultArtifactResolver.java

@@ -34,6 +34,7 @@
  * 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)
 public class DefaultArtifactResolver implements ArtifactResolver {
   public static final ArtifactResolver INSTANCE = new DefaultArtifactResolver();
 

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/DisplayDataTranslation.java

@@ -30,6 +30,7 @@
 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)
 public class DisplayDataTranslation {
   public static final String LABELLED_STRING = "beam:display_data:labelled_string:v1";
 

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/Environments.java

@@ -60,6 +60,7 @@
 import org.slf4j.LoggerFactory;
 
 /** Utilities for interacting with portability {@link Environment environments}. */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class Environments {
   private static final Logger LOG = LoggerFactory.getLogger(Environments.class);
 

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/External.java

@@ -68,6 +68,7 @@
  * high-level wrapper classes rather than this one.
  */
 @Experimental(Kind.PORTABILITY)
+@SuppressWarnings("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";

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ForwardingPTransform.java

@@ -33,6 +33,7 @@
  * 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)
 public abstract class ForwardingPTransform<InputT extends PInput, OutputT extends POutput>
     extends PTransform<InputT, OutputT> {
   protected abstract PTransform<InputT, OutputT> delegate();

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ModelCoderRegistrar.java

@@ -45,6 +45,7 @@
 
 /** The {@link CoderTranslatorRegistrar} for coders which are shared across languages. */
 @AutoService(CoderTranslatorRegistrar.class)
+@SuppressWarnings({"nullness", "keyfor"}) // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class ModelCoderRegistrar implements CoderTranslatorRegistrar {
 
   // The URNs for coders which are shared across languages

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformReplacements.java

@@ -28,6 +28,7 @@
 import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.Iterables;
 
 /** */
+@SuppressWarnings({"nullness", "keyfor"}) // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class PTransformReplacements {
   /**
    * Gets the singleton input of an {@link AppliedPTransform}, ignoring any additional inputs

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java

@@ -59,6 +59,7 @@
  * Utilities for converting {@link PTransform PTransforms} to {@link RunnerApi Runner API protocol
  * buffers}.
  */
+@SuppressWarnings({"nullness", "keyfor"}) // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class PTransformTranslation {
   // We specifically copy the values here so that they can be used in switch case statements
   // and we validate that the value matches the actual URN in the static block below.

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java

@@ -42,6 +42,7 @@
  * <p>This ensures maximum memoization of rehydrated components, which is semantically necessary for
  * {@link PCollection} and nice-to-have for other objects.
  */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class RehydratedComponents {
   private final Components components;
 

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReplacementOutputs.java

@@ -34,6 +34,7 @@
 import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.Iterables;
 
 /** Utility methods for creating {@link ReplacementOutput} for known styles of {@link POutput}. */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class ReplacementOutputs {
   private ReplacementOutputs() {}
 

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RunnerPCollectionView.java

@@ -33,6 +33,7 @@
 import org.checkerframework.checker.nullness.qual.Nullable;
 
 /** A {@link PCollectionView} created from the components of a {@link SideInput}. */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class RunnerPCollectionView<T> extends PValueBase implements PCollectionView<T> {
   private final TupleTag<Iterable<WindowedValue<?>>> tag;
   private final ViewFn<Iterable<WindowedValue<?>>, T> viewFn;

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SdkComponents.java

@@ -44,6 +44,7 @@
 import org.checkerframework.checker.nullness.qual.Nullable;
 
 /** SDK objects that will be represented at some later point within a {@link Components} object. */
+@SuppressWarnings({"nullness", "keyfor"}) // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class SdkComponents {
   private final String newIdPrefix;
   private final RunnerApi.Components.Builder componentsBuilder = RunnerApi.Components.newBuilder();

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SplittableParDoNaiveBounded.java

@@ -61,6 +61,7 @@
  * Utility transforms and overrides for running bounded splittable DoFn's naively, by implementing
  * {@link ProcessKeyedElements} using a simple {@link Reshuffle} and {@link ParDo}.
  */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class SplittableParDoNaiveBounded {
   /** Overrides a {@link ProcessKeyedElements} into {@link SplittableProcessNaive}. */
   public static class OverrideFactory<InputT, OutputT, RestrictionT, WatermarkEstimatorStateT>

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/Timer.java

@@ -49,6 +49,7 @@
  * org.apache.beam.sdk.state.Timer}.
  */
 @AutoValue
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public abstract class Timer<K> {
 
   /**

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/TriggerTranslation.java

@@ -47,6 +47,7 @@
 import org.joda.time.Instant;
 
 /** Utilities for working with {@link TriggerTranslation Triggers}. */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class TriggerTranslation implements Serializable {
 
   @VisibleForTesting static final ProtoConverter CONVERTER = new ProtoConverter();

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/UnboundedReadFromBoundedSource.java

@@ -70,6 +70,7 @@
  * <p>This transform is intended to be used by a runner during pipeline translation to convert a
  * Read.Bounded into a Read.Unbounded.
  */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class UnboundedReadFromBoundedSource<T> extends PTransform<PBegin, PCollection<T>> {
 
   private static final Logger LOG = LoggerFactory.getLogger(UnboundedReadFromBoundedSource.class);

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/UnconsumedReads.java

@@ -33,6 +33,7 @@
  * Utilities for ensuring that all {@link Read} {@link PTransform PTransforms} are consumed by some
  * {@link PTransform}.
  */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class UnconsumedReads {
   public static void ensureAllReadsConsumed(Pipeline pipeline) {
     final Set<PCollection<?>> unconsumed = new HashSet<>();

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WriteFilesTranslation.java

@@ -54,6 +54,7 @@
  * Utility methods for translating a {@link WriteFiles} to and from {@link RunnerApi}
  * representations.
  */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class WriteFilesTranslation {
 
   /** The URN for an unknown Java {@link FileBasedSink}. */

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/GreedyPCollectionFusers.java

@@ -40,6 +40,7 @@
 /**
  * A Fuser that constructs a fused pipeline by fusing as many PCollections into a stage as possible.
  */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 class GreedyPCollectionFusers {
   private static final Logger LOG = LoggerFactory.getLogger(GreedyPCollectionFusers.class);
 

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/GreedyPipelineFuser.java

@@ -55,6 +55,7 @@
 /** Fuses a {@link Pipeline} into some set of single-environment executable transforms. */
 // The use of NavigableSets everywhere provides consistent ordering but may be overkill for this
 // cause.
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class GreedyPipelineFuser {
   private static final Logger LOG = LoggerFactory.getLogger(GreedyPipelineFuser.class);
 

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/GreedyStageFuser.java

@@ -46,6 +46,7 @@
  * <p>A {@link PCollectionNode} with consumers that execute in an environment other than a stage is
  * materialized, and its consumers execute in independent stages.
  */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class GreedyStageFuser {
   // TODO: Provide a way to merge in a compatible subgraph (e.g. one where all of the siblings
   // consume a PCollection materialized by this subgraph and can be fused into it).

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/Networks.java

@@ -46,6 +46,7 @@
 import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.graph.NetworkBuilder;
 
 /** Static utility methods for {@link Network} instances that are directed. */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class Networks {
   /**
    * An abstract class that can be extended to apply a function in a type safe manner.

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/OutputDeduplicator.java

@@ -46,6 +46,7 @@
  * Utilities to insert synthetic {@link PCollectionNode PCollections} for {@link PCollection
  * PCollections} which are produced by multiple independently executable stages.
  */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 class OutputDeduplicator {
 
   /**

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/QueryablePipeline.java

@@ -74,6 +74,7 @@
  * A {@link Pipeline} which has additional methods to relate nodes in the graph relative to each
  * other.
  */
+@SuppressWarnings({"nullness", "keyfor"}) // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class QueryablePipeline {
   // TODO: Is it better to have the signatures here require nodes in almost all contexts, or should
   // they all take strings? Nodes gives some degree of type signalling that names might not, but

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/SplittableParDoExpander.java

@@ -42,6 +42,7 @@
  * href="https://github.com/apache/beam/blob/cb15994d5228f729dda922419b08520c8be8804e/model/pipeline/src/main/proto/beam_runner_api.proto#L279"
  * />
  */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class SplittableParDoExpander {
 
   /**

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/TrivialNativeTransformExpander.java

@@ -27,6 +27,7 @@
  * TrivialNativeTransformExpander is used to replace transforms with known URNs with their native
  * equivalent.
  */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class TrivialNativeTransformExpander {
   private static final Logger LOG = LoggerFactory.getLogger(TrivialNativeTransformExpander.class);
 

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/renderer/PipelineDotRenderer.java

@@ -25,6 +25,7 @@
 import org.apache.beam.sdk.values.PValue;
 
 /** A DOT renderer for BEAM {@link Pipeline} DAG. */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 public class PipelineDotRenderer implements Pipeline.PipelineVisitor {
   public static String toDotString(Pipeline pipeline) {
     final PipelineDotRenderer visitor = new PipelineDotRenderer();

runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/renderer/PortablePipelineDotRenderer.java

@@ -26,6 +26,7 @@
 /**
  * A DOT renderer for BEAM portable {@link org.apache.beam.model.pipeline.v1.RunnerApi.Pipeline}.
  */
+@SuppressWarnings("nullness") // TODO(https://issues.apache.org/jira/browse/BEAM-10402)
 class PortablePipelineDotRenderer {
   private final StringBuilder dotBuilder = new StringBuilder();
   private final Map<String, Integer> valueToProducerNodeId = new HashMap<>();