[Backport 2.x] [Spotless] Adds new line at end of java files

build.gradle

@@ -83,18 +83,18 @@ repositories {
 // Spotless checks will be added as PRs are applied to resolve each style issue is approved.
 spotless {
     java {
-//        target fileTree('.') {
-//            include '**/*.java', 'src/*/java/**/*.java'
-//            exclude '**/build/**', '**/build-*/**'
-//        }
+        target fileTree('.') {
+            include '**/*.java'
+            exclude '**/build/**', '**/build-*/**'
+        }
 //        importOrder()
 //        licenseHeader("/*\n" +
 //                " * Copyright OpenSearch Contributors\n" +
 //                " * SPDX-License-Identifier: Apache-2.0\n" +
-//                " */\n\n\n")
+//                " */\n\n")
 //        removeUnusedImports()
 //        trimTrailingWhitespace()
-//        endWithNewline()
+        endWithNewline()
 //        googleJavaFormat('1.17.0').reflowLongStrings().groupArtifact('com.google.googlejavaformat:google-java-format')
     }
 }

common/src/main/java/org/opensearch/sql/common/grok/Converter.java

@@ -1,168 +1,168 @@
-/*
- * Copyright OpenSearch Contributors
- * SPDX-License-Identifier: Apache-2.0
- */
-
-package org.opensearch.sql.common.grok;
-
-import java.time.Instant;
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-import java.time.OffsetDateTime;
-import java.time.ZoneId;
-import java.time.ZoneOffset;
-import java.time.ZonedDateTime;
-import java.time.format.DateTimeFormatter;
-import java.time.temporal.TemporalAccessor;
-import java.util.AbstractMap;
-import java.util.Arrays;
-import java.util.Collection;
-import java.util.List;
-import java.util.Map;
-import java.util.function.Function;
-import java.util.regex.Pattern;
-import java.util.stream.Collectors;
-
-/**
- * Convert String argument to the right type.
- */
-public class Converter {
-
-  public enum Type {
-    BYTE(Byte::valueOf),
-    BOOLEAN(Boolean::valueOf),
-    SHORT(Short::valueOf),
-    INT(Integer::valueOf, "integer"),
-    LONG(Long::valueOf),
-    FLOAT(Float::valueOf),
-    DOUBLE(Double::valueOf),
-    DATETIME(new DateConverter(), "date"),
-    STRING(v -> v, "text");
-
-    public final IConverter<? extends Object> converter;
-    public final List<String> aliases;
-
-    Type(IConverter<? extends Object> converter, String... aliases) {
-      this.converter = converter;
-      this.aliases = Arrays.asList(aliases);
-    }
-  }
-
-  private static final Pattern SPLITTER = Pattern.compile("[:;]");
-
-  private static final Map<String, Type> TYPES =
-      Arrays.stream(Type.values())
-          .collect(Collectors.toMap(t -> t.name().toLowerCase(), t -> t));
-
-  private static final Map<String, Type> TYPE_ALIASES =
-      Arrays.stream(Type.values())
-          .flatMap(type -> type.aliases.stream()
-              .map(alias -> new AbstractMap.SimpleEntry<>(alias, type)))
-          .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
-
-  private static Type getType(String key) {
-    key = key.toLowerCase();
-    Type type = TYPES.getOrDefault(key, TYPE_ALIASES.get(key));
-    if (type == null) {
-      throw new IllegalArgumentException("Invalid data type :" + key);
-    }
-    return type;
-  }
-
-  /**
-   * getConverters.
-   */
-  public static Map<String, IConverter<? extends Object>>
-      getConverters(Collection<String> groupNames, Object... params) {
-    return groupNames.stream()
-        .filter(Converter::containsDelimiter)
-        .collect(Collectors.toMap(Function.identity(), key -> {
-          String[] list = splitGrokPattern(key);
-          IConverter<? extends Object> converter = getType(list[1]).converter;
-          if (list.length == 3) {
-            converter = converter.newConverter(list[2], params);
-          }
-          return converter;
-        }));
-  }
-
-  /**
-   * getGroupTypes.
-   */
-  public static Map<String, Type> getGroupTypes(Collection<String> groupNames) {
-    return groupNames.stream()
-        .filter(Converter::containsDelimiter)
-        .map(Converter::splitGrokPattern)
-        .collect(Collectors.toMap(
-            l -> l[0],
-            l -> getType(l[1])
-        ));
-  }
-
-  public static String extractKey(String key) {
-    return splitGrokPattern(key)[0];
-  }
-
-  private static boolean containsDelimiter(String string) {
-    return string.indexOf(':') >= 0 || string.indexOf(';') >= 0;
-  }
-
-  private static String[] splitGrokPattern(String string) {
-    return SPLITTER.split(string, 3);
-  }
-
-  interface IConverter<T> {
-
-    T convert(String value);
-
-    default IConverter<T> newConverter(String param, Object... params) {
-      return this;
-    }
-  }
-
-
-  static class DateConverter implements IConverter<Instant> {
-
-    private final DateTimeFormatter formatter;
-    private final ZoneId timeZone;
-
-    public DateConverter() {
-      this.formatter = DateTimeFormatter.ISO_DATE_TIME;
-      this.timeZone = ZoneOffset.UTC;
-    }
-
-    private DateConverter(DateTimeFormatter formatter, ZoneId timeZone) {
-      this.formatter = formatter;
-      this.timeZone = timeZone;
-    }
-
-    @Override
-    public Instant convert(String value) {
-      TemporalAccessor dt = formatter
-          .parseBest(value.trim(), ZonedDateTime::from, LocalDateTime::from, OffsetDateTime::from,
-              Instant::from,
-              LocalDate::from);
-      if (dt instanceof ZonedDateTime) {
-        return ((ZonedDateTime) dt).toInstant();
-      } else if (dt instanceof LocalDateTime) {
-        return ((LocalDateTime) dt).atZone(timeZone).toInstant();
-      } else if (dt instanceof OffsetDateTime) {
-        return ((OffsetDateTime) dt).atZoneSameInstant(timeZone).toInstant();
-      } else if (dt instanceof Instant) {
-        return ((Instant) dt);
-      } else if (dt instanceof LocalDate) {
-        return ((LocalDate) dt).atStartOfDay(timeZone).toInstant();
-      } else {
-        return null;
-      }
-    }
-
-    @Override
-    public DateConverter newConverter(String param, Object... params) {
-      if (!(params.length == 1 && params[0] instanceof ZoneId)) {
-        throw new IllegalArgumentException("Invalid parameters");
-      }
-      return new DateConverter(DateTimeFormatter.ofPattern(param), (ZoneId) params[0]);
-    }
-  }
-}
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package org.opensearch.sql.common.grok;
+
+import java.time.Instant;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.OffsetDateTime;
+import java.time.ZoneId;
+import java.time.ZoneOffset;
+import java.time.ZonedDateTime;
+import java.time.format.DateTimeFormatter;
+import java.time.temporal.TemporalAccessor;
+import java.util.AbstractMap;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.List;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
+
+/**
+ * Convert String argument to the right type.
+ */
+public class Converter {
+
+  public enum Type {
+    BYTE(Byte::valueOf),
+    BOOLEAN(Boolean::valueOf),
+    SHORT(Short::valueOf),
+    INT(Integer::valueOf, "integer"),
+    LONG(Long::valueOf),
+    FLOAT(Float::valueOf),
+    DOUBLE(Double::valueOf),
+    DATETIME(new DateConverter(), "date"),
+    STRING(v -> v, "text");
+
+    public final IConverter<? extends Object> converter;
+    public final List<String> aliases;
+
+    Type(IConverter<? extends Object> converter, String... aliases) {
+      this.converter = converter;
+      this.aliases = Arrays.asList(aliases);
+    }
+  }
+
+  private static final Pattern SPLITTER = Pattern.compile("[:;]");
+
+  private static final Map<String, Type> TYPES =
+      Arrays.stream(Type.values())
+          .collect(Collectors.toMap(t -> t.name().toLowerCase(), t -> t));
+
+  private static final Map<String, Type> TYPE_ALIASES =
+      Arrays.stream(Type.values())
+          .flatMap(type -> type.aliases.stream()
+              .map(alias -> new AbstractMap.SimpleEntry<>(alias, type)))
+          .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+
+  private static Type getType(String key) {
+    key = key.toLowerCase();
+    Type type = TYPES.getOrDefault(key, TYPE_ALIASES.get(key));
+    if (type == null) {
+      throw new IllegalArgumentException("Invalid data type :" + key);
+    }
+    return type;
+  }
+
+  /**
+   * getConverters.
+   */
+  public static Map<String, IConverter<? extends Object>>
+      getConverters(Collection<String> groupNames, Object... params) {
+    return groupNames.stream()
+        .filter(Converter::containsDelimiter)
+        .collect(Collectors.toMap(Function.identity(), key -> {
+          String[] list = splitGrokPattern(key);
+          IConverter<? extends Object> converter = getType(list[1]).converter;
+          if (list.length == 3) {
+            converter = converter.newConverter(list[2], params);
+          }
+          return converter;
+        }));
+  }
+
+  /**
+   * getGroupTypes.
+   */
+  public static Map<String, Type> getGroupTypes(Collection<String> groupNames) {
+    return groupNames.stream()
+        .filter(Converter::containsDelimiter)
+        .map(Converter::splitGrokPattern)
+        .collect(Collectors.toMap(
+            l -> l[0],
+            l -> getType(l[1])
+        ));
+  }
+
+  public static String extractKey(String key) {
+    return splitGrokPattern(key)[0];
+  }
+
+  private static boolean containsDelimiter(String string) {
+    return string.indexOf(':') >= 0 || string.indexOf(';') >= 0;
+  }
+
+  private static String[] splitGrokPattern(String string) {
+    return SPLITTER.split(string, 3);
+  }
+
+  interface IConverter<T> {
+
+    T convert(String value);
+
+    default IConverter<T> newConverter(String param, Object... params) {
+      return this;
+    }
+  }
+
+
+  static class DateConverter implements IConverter<Instant> {
+
+    private final DateTimeFormatter formatter;
+    private final ZoneId timeZone;
+
+    public DateConverter() {
+      this.formatter = DateTimeFormatter.ISO_DATE_TIME;
+      this.timeZone = ZoneOffset.UTC;
+    }
+
+    private DateConverter(DateTimeFormatter formatter, ZoneId timeZone) {
+      this.formatter = formatter;
+      this.timeZone = timeZone;
+    }
+
+    @Override
+    public Instant convert(String value) {
+      TemporalAccessor dt = formatter
+          .parseBest(value.trim(), ZonedDateTime::from, LocalDateTime::from, OffsetDateTime::from,
+              Instant::from,
+              LocalDate::from);
+      if (dt instanceof ZonedDateTime) {
+        return ((ZonedDateTime) dt).toInstant();
+      } else if (dt instanceof LocalDateTime) {
+        return ((LocalDateTime) dt).atZone(timeZone).toInstant();
+      } else if (dt instanceof OffsetDateTime) {
+        return ((OffsetDateTime) dt).atZoneSameInstant(timeZone).toInstant();
+      } else if (dt instanceof Instant) {
+        return ((Instant) dt);
+      } else if (dt instanceof LocalDate) {
+        return ((LocalDate) dt).atStartOfDay(timeZone).toInstant();
+      } else {
+        return null;
+      }
+    }
+
+    @Override
+    public DateConverter newConverter(String param, Object... params) {
+      if (!(params.length == 1 && params[0] instanceof ZoneId)) {
+        throw new IllegalArgumentException("Invalid parameters");
+      }
+      return new DateConverter(DateTimeFormatter.ofPattern(param), (ZoneId) params[0]);
+    }
+  }
+}

core/src/main/java/org/opensearch/sql/ast/tree/RareTopN.java

@@ -57,4 +57,3 @@ public enum CommandType {
     RARE
   }
 }
-

core/src/main/java/org/opensearch/sql/expression/operator/arthmetic/ArithmeticFunction.java

@@ -265,4 +265,4 @@ private static DefaultFunctionResolver subtract() {
   private static DefaultFunctionResolver subtractFunction() {
     return subtractBase(BuiltinFunctionName.SUBTRACTFUNCTION.getName());
   }
-}
+}

core/src/main/java/org/opensearch/sql/expression/text/TextFunction.java

@@ -379,4 +379,3 @@ private static ExprValue exprReverse(ExprValue str) {
     return new ExprStringValue(new StringBuilder(str.stringValue()).reverse().toString());
   }
 }
-

core/src/test/java/org/opensearch/sql/planner/logical/LogicalRelationTest.java

@@ -33,4 +33,4 @@ public void logicalRelationWithDataSourceHasNoInput() {
     assertEquals(0, relation.getChild().size());
   }
 
-}
+}

core/src/test/java/org/opensearch/sql/planner/streaming/watermark/BoundedOutOfOrderWatermarkGeneratorTest.java

@@ -58,4 +58,4 @@ public AssertionHelper shouldGenerateWatermark(long expected) {
       return this;
     }
   }
-}
+}

core/src/test/java/org/opensearch/sql/planner/streaming/windowing/WindowTest.java

@@ -18,4 +18,4 @@ void test() {
     assertEquals(2000, window.getEndTime());
     assertEquals(1999, window.maxTimestamp());
   }
-}
+}