nullness

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/action/ActionFactory.java

@@ -30,15 +30,16 @@
  * query. The instances created are all singletons.
  */
 // transient fields are un-initialized, because we start them during the first fetch call (with the
-// singleton pattern)
+// singleton pattern).
+@SuppressWarnings("uninitialized")
 public class ActionFactory implements Serializable {
 
   private static final long serialVersionUID = -4060958761369602619L;
-  private transient DataChangeRecordAction dataChangeRecordActionInstance = null;
-  private transient HeartbeatRecordAction heartbeatRecordActionInstance = null;
-  private transient ChildPartitionsRecordAction childPartitionsRecordActionInstance = null;
-  private transient QueryChangeStreamAction queryChangeStreamActionInstance = null;
-  private transient DetectNewPartitionsAction detectNewPartitionsActionInstance = null;
+  private transient DataChangeRecordAction dataChangeRecordActionInstance;
+  private transient HeartbeatRecordAction heartbeatRecordActionInstance;
+  private transient ChildPartitionsRecordAction childPartitionsRecordActionInstance;
+  private transient QueryChangeStreamAction queryChangeStreamActionInstance;
+  private transient DetectNewPartitionsAction detectNewPartitionsActionInstance;
 
   /**
    * Creates and returns a singleton instance of an action class capable of processing {@link

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/dao/DaoFactory.java

@@ -30,13 +30,14 @@
 // transient fields are un-initialized, because we start them during the first fetch call (with the
 // singleton pattern)
 // nullness checks for metadata instance and database are handled in the constructor
+@SuppressWarnings({"uninitialized", "nullness"})
 public class DaoFactory implements Serializable {
 
   private static final long serialVersionUID = 7929063669009832487L;
 
-  private transient PartitionMetadataAdminDao partitionMetadataAdminDao = null;
-  private transient PartitionMetadataDao partitionMetadataDaoInstance = null;
-  private transient ChangeStreamDao changeStreamDaoInstance = null;
+  private transient PartitionMetadataAdminDao partitionMetadataAdminDao;
+  private transient PartitionMetadataDao partitionMetadataDaoInstance;
+  private transient ChangeStreamDao changeStreamDaoInstance;
 
   private final SpannerConfig changeStreamSpannerConfig;
   private final SpannerConfig metadataSpannerConfig;

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/mapper/MapperFactory.java

@@ -25,12 +25,13 @@
  */
 // transient fields are un-initialized, because we start them during the first fetch call (with the
 // singleton pattern)
+@SuppressWarnings("nullness")
 public class MapperFactory implements Serializable {
 
   private static final long serialVersionUID = -813434573067800902L;
 
-  private transient ChangeStreamRecordMapper changeStreamRecordMapperInstance = null;
-  private transient PartitionMetadataMapper partitionMetadataMapperInstance = null;
+  private transient ChangeStreamRecordMapper changeStreamRecordMapperInstance;
+  private transient PartitionMetadataMapper partitionMetadataMapperInstance;
 
   /**
    * Creates and returns a singleton instance of a mapper class capable of transforming a {@link