Add annotations

Author: misolt

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/Connector.java

@@ -24,6 +24,7 @@
 import java.time.ZonedDateTime;
 import java.util.List;
 import javax.annotation.Nonnull;
+import javax.annotation.OverridingMethodsMustInvokeSuper;
 
 /** @author shevek */
 public interface Connector {
@@ -50,7 +51,8 @@ default String getDescription() {
    * @param arguments cli params
    * @throws RuntimeException if incorrect set of arguments passed to the particular connector
    */
-  default void validate(ConnectorArguments arguments) {}
+  @OverridingMethodsMustInvokeSuper
+  default void validate(@Nonnull ConnectorArguments arguments) {}
 
   default void validateDateRange(ConnectorArguments arguments) {
     ZonedDateTime startDate = arguments.getStartDate();

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/airflow/AirflowConnector.java

@@ -209,7 +209,7 @@ private static void addQueryTask(
   }
 
   @Override
-  public void validate(ConnectorArguments arguments) {
+  public void validate(@Nonnull ConnectorArguments arguments) {
     Preconditions.checkState(arguments.isAssessment(), "--assessment flag is required");
     Preconditions.checkState(
         arguments.getDriverPaths() != null && !arguments.getDriverPaths().isEmpty(),

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/cloudera/manager/ClouderaManagerConnector.java

@@ -129,7 +129,7 @@ public ClouderaManagerHandle open(@Nonnull ConnectorArguments arguments) throws
   }
 
   @Override
-  public void validate(ConnectorArguments arguments) {
+  public void validate(@Nonnull ConnectorArguments arguments) {
     String clouderaUri = arguments.getUri();
     Preconditions.checkNotNull(clouderaUri, "--url for Cloudera Manager API is required");
 

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/hadoop/oozie/OozieConnector.java

@@ -79,7 +79,7 @@ public String getDefaultFileName(boolean isAssessment, Clock clock) {
   }
 
   @Override
-  public void validate(ConnectorArguments arguments) {
+  public void validate(@Nonnull ConnectorArguments arguments) {
     Preconditions.checkState(arguments.isAssessment(), "--assessment flag is required");
 
     validateDateRange(arguments);

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/snowflake/SnowflakeLogsConnector.java

@@ -161,7 +161,7 @@ private TaskDescription(
   }
 
   @Override
-  public final void validate(ConnectorArguments arguments) {
+  public final void validate(@Nonnull ConnectorArguments arguments) {
     super.validate(arguments);
 
     if (arguments.isAssessment() && arguments.hasQueryLogEarliestTimestamp()) {