[FLINK-20651] Format code with Spotless/google-java-format

Author: Rufus Refactor

flink-annotations/src/main/java/org/apache/flink/annotation/Experimental.java

@@ -26,15 +26,13 @@
 /**
  * Annotation to mark classes for experimental use.
  *
- * <p>Classes with this annotation are neither battle-tested nor stable, and may be changed or removed
- * in future versions.
- *
- * <p>This annotation also excludes classes with evolving interfaces / signatures
- * annotated with {@link Public} and {@link PublicEvolving}.
+ * <p>Classes with this annotation are neither battle-tested nor stable, and may be changed or
+ * removed in future versions.
  *
+ * <p>This annotation also excludes classes with evolving interfaces / signatures annotated with
+ * {@link Public} and {@link PublicEvolving}.
  */
 @Documented
-@Target({ElementType.TYPE, ElementType.METHOD, ElementType.FIELD, ElementType.CONSTRUCTOR })
+@Target({ElementType.TYPE, ElementType.METHOD, ElementType.FIELD, ElementType.CONSTRUCTOR})
 @Public
-public @interface Experimental {
-}
+public @interface Experimental {}

flink-annotations/src/main/java/org/apache/flink/annotation/Internal.java

@@ -29,7 +29,6 @@
  * <p>Developer APIs are stable but internal to Flink and might change across releases.
  */
 @Documented
-@Target({ ElementType.TYPE, ElementType.METHOD, ElementType.CONSTRUCTOR })
+@Target({ElementType.TYPE, ElementType.METHOD, ElementType.CONSTRUCTOR})
 @Public
-public @interface Internal {
-}
+public @interface Internal {}

flink-annotations/src/main/java/org/apache/flink/annotation/Public.java

@@ -26,8 +26,9 @@
 /**
  * Annotation for marking classes as public, stable interfaces.
  *
- * <p>Classes, methods and fields with this annotation are stable across minor releases (1.0, 1.1, 1.2). In other words,
- * applications using @Public annotated classes will compile against newer versions of the same major release.
+ * <p>Classes, methods and fields with this annotation are stable across minor releases (1.0, 1.1,
+ * 1.2). In other words, applications using @Public annotated classes will compile against newer
+ * versions of the same major release.
  *
  * <p>Only major releases (1.0, 2.0, 3.0) can break interfaces with this annotation.
  */

flink-annotations/src/main/java/org/apache/flink/annotation/PublicEvolving.java

@@ -30,12 +30,10 @@
  * However, their interfaces and signatures are not considered to be stable and might be changed
  * across versions.
  *
- * <p>This annotation also excludes methods and classes with evolving interfaces / signatures
- * within classes annotated with {@link Public}.
- *
+ * <p>This annotation also excludes methods and classes with evolving interfaces / signatures within
+ * classes annotated with {@link Public}.
  */
 @Documented
-@Target({ ElementType.TYPE, ElementType.METHOD, ElementType.FIELD, ElementType.CONSTRUCTOR })
+@Target({ElementType.TYPE, ElementType.METHOD, ElementType.FIELD, ElementType.CONSTRUCTOR})
 @Public
-public @interface PublicEvolving {
-}
+public @interface PublicEvolving {}

flink-annotations/src/main/java/org/apache/flink/annotation/VisibleForTesting.java

@@ -24,14 +24,14 @@
 import java.lang.annotation.Target;
 
 /**
- * This annotations declares that a function, field, constructor, or entire type, is only visible for
- * testing purposes.
+ * This annotations declares that a function, field, constructor, or entire type, is only visible
+ * for testing purposes.
  *
  * <p>This annotation is typically attached when for example a method should be {@code private}
  * (because it is not intended to be called externally), but cannot be declared private, because
  * some tests need to have access to it.
  */
 @Documented
-@Target({ ElementType.TYPE, ElementType.METHOD, ElementType.FIELD, ElementType.CONSTRUCTOR })
+@Target({ElementType.TYPE, ElementType.METHOD, ElementType.FIELD, ElementType.CONSTRUCTOR})
 @Internal
 public @interface VisibleForTesting {}

flink-annotations/src/main/java/org/apache/flink/annotation/docs/ConfigGroup.java

@@ -23,14 +23,15 @@
 import java.lang.annotation.Target;
 
 /**
- * A class that specifies a group of config options. The name of the group will be used as the basis for the
- * filename of the generated html file, as defined in {@link ConfigOptionsDocGenerator}.
+ * A class that specifies a group of config options. The name of the group will be used as the basis
+ * for the filename of the generated html file, as defined in {@link ConfigOptionsDocGenerator}.
  *
  * @see ConfigGroups
  */
 @Target({})
 @Internal
 public @interface ConfigGroup {
-	String name();
-	String keyPrefix();
+    String name();
+
+    String keyPrefix();
 }

flink-annotations/src/main/java/org/apache/flink/annotation/docs/ConfigGroups.java

@@ -26,14 +26,15 @@
 import java.lang.annotation.Target;
 
 /**
- * Annotation used on classes containing config options that enables the separation of options into different
- * tables based on key prefixes. A config option is assigned to a {@link ConfigGroup} if the option key matches
- * the group prefix. If a key matches multiple prefixes the longest matching prefix takes priority. An option is never
- * assigned to multiple groups. Options that don't match any group are implicitly added to a default group.
+ * Annotation used on classes containing config options that enables the separation of options into
+ * different tables based on key prefixes. A config option is assigned to a {@link ConfigGroup} if
+ * the option key matches the group prefix. If a key matches multiple prefixes the longest matching
+ * prefix takes priority. An option is never assigned to multiple groups. Options that don't match
+ * any group are implicitly added to a default group.
  */
 @Target(ElementType.TYPE)
 @Retention(RetentionPolicy.RUNTIME)
 @Internal
 public @interface ConfigGroups {
-	ConfigGroup[] groups() default {};
+    ConfigGroup[] groups() default {};
 }

flink-annotations/src/main/java/org/apache/flink/annotation/docs/Documentation.java

@@ -25,139 +25,131 @@
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
 
-/**
- * Collection of annotations to modify the behavior of the documentation generators.
- */
+/** Collection of annotations to modify the behavior of the documentation generators. */
 public final class Documentation {
 
-	/**
-	 * Annotation used on config option fields to override the documented default.
-	 */
-	@Target(ElementType.FIELD)
-	@Retention(RetentionPolicy.RUNTIME)
-	@Internal
-	public @interface OverrideDefault {
-		String value();
-	}
-
-	/**
-	 * Annotation used on config option fields to include them in specific sections. Sections are groups of options
-	 * that are aggregated across option classes, with each group being placed into a dedicated file.
-	 *
-	 * <p>The {@link Section#position()} argument controls the position in the generated table, with lower values
-	 * being placed at the top. Fields with the same position are sorted alphabetically by key.
-	 */
-	@Target(ElementType.FIELD)
-	@Retention(RetentionPolicy.RUNTIME)
-	@Internal
-	public @interface Section {
-
-		/**
-		 * The sections in the config docs where this option should be included.
-		 */
-		String[] value() default {};
-
-		/**
-		 * The relative position of the option in its section.
-		 */
-		int position() default Integer.MAX_VALUE;
-	}
-
-	/**
-	 * Constants for section names.
-	 */
-	public static final class Sections {
-
-		public static final String COMMON_HOST_PORT = "common_host_port";
-		public static final String COMMON_STATE_BACKENDS = "common_state_backends";
-		public static final String COMMON_HIGH_AVAILABILITY = "common_high_availability";
-		public static final String COMMON_HIGH_AVAILABILITY_ZOOKEEPER = "common_high_availability_zk";
-		public static final String COMMON_MEMORY = "common_memory";
-		public static final String COMMON_MISCELLANEOUS = "common_miscellaneous";
-
-		public static final String SECURITY_SSL = "security_ssl";
-		public static final String SECURITY_AUTH_KERBEROS = "security_auth_kerberos";
-		public static final String SECURITY_AUTH_ZOOKEEPER = "security_auth_zk";
-
-		public static final String STATE_BACKEND_ROCKSDB = "state_backend_rocksdb";
-
-		public static final String EXPERT_CLASS_LOADING = "expert_class_loading";
-		public static final String EXPERT_DEBUGGING_AND_TUNING = "expert_debugging_and_tuning";
-		public static final String EXPERT_SCHEDULING = "expert_scheduling";
-		public static final String EXPERT_FAULT_TOLERANCE = "expert_fault_tolerance";
-		public static final String EXPERT_STATE_BACKENDS = "expert_state_backends";
-		public static final String EXPERT_REST = "expert_rest";
-		public static final String EXPERT_HIGH_AVAILABILITY = "expert_high_availability";
-		public static final String EXPERT_ZOOKEEPER_HIGH_AVAILABILITY = "expert_high_availability_zk";
-		public static final String EXPERT_KUBERNETES_HIGH_AVAILABILITY = "expert_high_availability_k8s";
-		public static final String EXPERT_SECURITY_SSL = "expert_security_ssl";
-		public static final String EXPERT_ROCKSDB = "expert_rocksdb";
-		public static final String EXPERT_CLUSTER = "expert_cluster";
-
-		public static final String ALL_JOB_MANAGER = "all_jobmanager";
-		public static final String ALL_TASK_MANAGER = "all_taskmanager";
-		public static final String ALL_TASK_MANAGER_NETWORK = "all_taskmanager_network";
-
-		public static final String DEPRECATED_FILE_SINKS = "deprecated_file_sinks";
-
-		private Sections() {}
-	}
-
-	/**
-	 * Annotation used on table config options for adding meta data labels.
-	 *
-	 * <p>The {@link TableOption#execMode()} argument indicates the execution mode the config works for
-	 * (batch, streaming or both).
-	 */
-	@Target(ElementType.FIELD)
-	@Retention(RetentionPolicy.RUNTIME)
-	@Internal
-	public @interface TableOption {
-		ExecMode execMode();
-	}
-
-	/**
-	 * The execution mode the config works for.
-	 */
-	public enum ExecMode {
-
-		BATCH("Batch"), STREAMING("Streaming"), BATCH_STREAMING("Batch and Streaming");
-
-		private final String name;
-
-		ExecMode(String name) {
-			this.name = name;
-		}
-
-		@Override
-		public String toString() {
-			return name;
-		}
-	}
-
-	/**
-	 * Annotation used on config option fields or options class to mark them as a suffix-option; i.e., a config option
-	 * where the key is only a suffix, with the prefix being dynamically provided at runtime.
-	 */
-	@Target({ElementType.FIELD, ElementType.TYPE})
-	@Retention(RetentionPolicy.RUNTIME)
-	@Internal
-	public @interface SuffixOption {
-	}
-
-	/**
-	 * Annotation used on config option fields or REST API message headers to exclude it from documentation.
-	 */
-	@Target({ElementType.FIELD, ElementType.TYPE})
-	@Retention(RetentionPolicy.RUNTIME)
-	@Internal
-	public @interface ExcludeFromDocumentation {
-		/**
-		 * The optional reason why it is excluded from documentation.
-		 */
-		String value() default "";
-	}
-
-	private Documentation(){
-	}
+    /** Annotation used on config option fields to override the documented default. */
+    @Target(ElementType.FIELD)
+    @Retention(RetentionPolicy.RUNTIME)
+    @Internal
+    public @interface OverrideDefault {
+        String value();
+    }
+
+    /**
+     * Annotation used on config option fields to include them in specific sections. Sections are
+     * groups of options that are aggregated across option classes, with each group being placed
+     * into a dedicated file.
+     *
+     * <p>The {@link Section#position()} argument controls the position in the generated table, with
+     * lower values being placed at the top. Fields with the same position are sorted alphabetically
+     * by key.
+     */
+    @Target(ElementType.FIELD)
+    @Retention(RetentionPolicy.RUNTIME)
+    @Internal
+    public @interface Section {
+
+        /** The sections in the config docs where this option should be included. */
+        String[] value() default {};
+
+        /** The relative position of the option in its section. */
+        int position() default Integer.MAX_VALUE;
+    }
+
+    /** Constants for section names. */
+    public static final class Sections {
+
+        public static final String COMMON_HOST_PORT = "common_host_port";
+        public static final String COMMON_STATE_BACKENDS = "common_state_backends";
+        public static final String COMMON_HIGH_AVAILABILITY = "common_high_availability";
+        public static final String COMMON_HIGH_AVAILABILITY_ZOOKEEPER =
+                "common_high_availability_zk";
+        public static final String COMMON_MEMORY = "common_memory";
+        public static final String COMMON_MISCELLANEOUS = "common_miscellaneous";
+
+        public static final String SECURITY_SSL = "security_ssl";
+        public static final String SECURITY_AUTH_KERBEROS = "security_auth_kerberos";
+        public static final String SECURITY_AUTH_ZOOKEEPER = "security_auth_zk";
+
+        public static final String STATE_BACKEND_ROCKSDB = "state_backend_rocksdb";
+
+        public static final String EXPERT_CLASS_LOADING = "expert_class_loading";
+        public static final String EXPERT_DEBUGGING_AND_TUNING = "expert_debugging_and_tuning";
+        public static final String EXPERT_SCHEDULING = "expert_scheduling";
+        public static final String EXPERT_FAULT_TOLERANCE = "expert_fault_tolerance";
+        public static final String EXPERT_STATE_BACKENDS = "expert_state_backends";
+        public static final String EXPERT_REST = "expert_rest";
+        public static final String EXPERT_HIGH_AVAILABILITY = "expert_high_availability";
+        public static final String EXPERT_ZOOKEEPER_HIGH_AVAILABILITY =
+                "expert_high_availability_zk";
+        public static final String EXPERT_KUBERNETES_HIGH_AVAILABILITY =
+                "expert_high_availability_k8s";
+        public static final String EXPERT_SECURITY_SSL = "expert_security_ssl";
+        public static final String EXPERT_ROCKSDB = "expert_rocksdb";
+        public static final String EXPERT_CLUSTER = "expert_cluster";
+
+        public static final String ALL_JOB_MANAGER = "all_jobmanager";
+        public static final String ALL_TASK_MANAGER = "all_taskmanager";
+        public static final String ALL_TASK_MANAGER_NETWORK = "all_taskmanager_network";
+
+        public static final String DEPRECATED_FILE_SINKS = "deprecated_file_sinks";
+
+        private Sections() {}
+    }
+
+    /**
+     * Annotation used on table config options for adding meta data labels.
+     *
+     * <p>The {@link TableOption#execMode()} argument indicates the execution mode the config works
+     * for (batch, streaming or both).
+     */
+    @Target(ElementType.FIELD)
+    @Retention(RetentionPolicy.RUNTIME)
+    @Internal
+    public @interface TableOption {
+        ExecMode execMode();
+    }
+
+    /** The execution mode the config works for. */
+    public enum ExecMode {
+        BATCH("Batch"),
+        STREAMING("Streaming"),
+        BATCH_STREAMING("Batch and Streaming");
+
+        private final String name;
+
+        ExecMode(String name) {
+            this.name = name;
+        }
+
+        @Override
+        public String toString() {
+            return name;
+        }
+    }
+
+    /**
+     * Annotation used on config option fields or options class to mark them as a suffix-option;
+     * i.e., a config option where the key is only a suffix, with the prefix being dynamically
+     * provided at runtime.
+     */
+    @Target({ElementType.FIELD, ElementType.TYPE})
+    @Retention(RetentionPolicy.RUNTIME)
+    @Internal
+    public @interface SuffixOption {}
+
+    /**
+     * Annotation used on config option fields or REST API message headers to exclude it from
+     * documentation.
+     */
+    @Target({ElementType.FIELD, ElementType.TYPE})
+    @Retention(RetentionPolicy.RUNTIME)
+    @Internal
+    public @interface ExcludeFromDocumentation {
+        /** The optional reason why it is excluded from documentation. */
+        String value() default "";
+    }
+
+    private Documentation() {}
 }