spotlessApply

Signed-off-by: Sean Kao <[email protected]>
opensearch-project · Mar 19, 2024 · e26053a · e26053a
1 parent 2a08946
commit e26053a
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 14 deletions.
diff --git a/spark/src/main/java/org/opensearch/sql/spark/dispatcher/model/IndexQueryDetails.java b/spark/src/main/java/org/opensearch/sql/spark/dispatcher/model/IndexQueryDetails.java
@@ -8,7 +8,6 @@
 import static org.apache.commons.lang3.StringUtils.strip;
 
 import java.util.Set;
-
 import lombok.EqualsAndHashCode;
 import lombok.Getter;
 import org.apache.commons.lang3.StringUtils;

diff --git a/spark/src/test/java/org/opensearch/sql/spark/asyncquery/IndexQuerySpecTest.java b/spark/src/test/java/org/opensearch/sql/spark/asyncquery/IndexQuerySpecTest.java
@@ -59,10 +59,10 @@ public class IndexQuerySpecTest extends AsyncQueryExecutorServiceSpec {
 
   public final FlintDatasetMock LEGACY_SPECIAL_CHARACTERS =
       new FlintDatasetMock(
-          "DROP SKIPPING INDEX ON mys3.default." + specialName,
-          REFRESH_SCI,
-          FlintIndexType.SKIPPING,
-          "flint_mys3_default_" + encodedName + "_skipping_index")
+              "DROP SKIPPING INDEX ON mys3.default." + specialName,
+              REFRESH_SCI,
+              FlintIndexType.SKIPPING,
+              "flint_mys3_default_" + encodedName + "_skipping_index")
           .isLegacy(true)
           .isSpecialCharacter(true);
 
@@ -82,10 +82,10 @@ public class IndexQuerySpecTest extends AsyncQueryExecutorServiceSpec {
           .latestId("ZmxpbnRfbXlzM19kZWZhdWx0X2h0dHBfbG9nc19jb3ZlcmluZ19pbmRleA==");
   public final FlintDatasetMock MV =
       new FlintDatasetMock(
-          "DROP MATERIALIZED VIEW mys3.default.http_logs_metrics",
-          REFRESH_MV,
-          FlintIndexType.MATERIALIZED_VIEW,
-          "flint_mys3_default_http_logs_metrics")
+              "DROP MATERIALIZED VIEW mys3.default.http_logs_metrics",
+              REFRESH_MV,
+              FlintIndexType.MATERIALIZED_VIEW,
+              "flint_mys3_default_http_logs_metrics")
           .latestId("ZmxpbnRfbXlzM19kZWZhdWx0X2h0dHBfbG9nc19tZXRyaWNz");
   public final FlintDatasetMock SPECIAL_CHARACTERS =
       new FlintDatasetMock(
@@ -94,7 +94,8 @@ public class IndexQuerySpecTest extends AsyncQueryExecutorServiceSpec {
               FlintIndexType.SKIPPING,
               "flint_mys3_default_" + encodedName + "_skipping_index")
           .isSpecialCharacter(true)
-          .latestId("ZmxpbnRfbXlzM19kZWZhdWx0X3Rlc3QlMjAlMmMlM2ElMjIlMmIlMmYlNWMlN2MlM2YlMjMlM2UlM2Nfc2tpcHBpbmdfaW5kZXg=");
+          .latestId(
+              "ZmxpbnRfbXlzM19kZWZhdWx0X3Rlc3QlMjAlMmMlM2ElMjIlMmIlMmYlNWMlN2MlM2YlMjMlM2UlM2Nfc2tpcHBpbmdfaW5kZXg=");
 
   public final String CREATE_SI_AUTO =
       "CREATE SKIPPING INDEX ON mys3.default.http_logs"

diff --git a/spark/src/test/java/org/opensearch/sql/spark/asyncquery/IndexQuerySpecVacuumTest.java b/spark/src/test/java/org/opensearch/sql/spark/asyncquery/IndexQuerySpecVacuumTest.java
@@ -56,9 +56,9 @@ public class IndexQuerySpecVacuumTest extends AsyncQueryExecutorServiceSpec {
               MATERIALIZED_VIEW,
               "flint_mys3_default_http_logs_metrics"),
           mockDataset(
-              "VACUUM SKIPPING INDEX ON mys3.default.`test ,:\"+/\\|?#><`",
-              SKIPPING,
-              "flint_mys3_default_test%20%2c%3a%22%2b%2f%5c%7c%3f%23%3e%3c_skipping_index")
+                  "VACUUM SKIPPING INDEX ON mys3.default.`test ,:\"+/\\|?#><`",
+                  SKIPPING,
+                  "flint_mys3_default_test%20%2c%3a%22%2b%2f%5c%7c%3f%23%3e%3c_skipping_index")
               .isSpecialCharacter(true));
 
   @Test

diff --git a/spark/src/test/java/org/opensearch/sql/spark/flint/IndexQueryDetailsTest.java b/spark/src/test/java/org/opensearch/sql/spark/flint/IndexQueryDetailsTest.java
@@ -111,7 +111,8 @@ public void sanitizedIndexName() {
         "flint_mys3_default_test%20%2c%3a%22%2b%2f%5c%7c%3f%23%3e%3c_skipping_index",
         IndexQueryDetails.builder()
             .indexName("invalid")
-            .fullyQualifiedTableName(new FullyQualifiedTableName("mys3.default.`test ,:\"+/\\|?#><`"))
+            .fullyQualifiedTableName(
+                new FullyQualifiedTableName("mys3.default.`test ,:\"+/\\|?#><`"))
             .indexOptions(new FlintIndexOptions())
             .indexQueryActionType(IndexQueryActionType.DROP)
             .indexType(FlintIndexType.SKIPPING)