Fix code format

Signed-off-by: Chen Dai <[email protected]>
opensearch-project · Mar 19, 2024 · 24c37c1 · 24c37c1
1 parent 1555ca9
commit 24c37c1
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 5 deletions.
diff --git a/spark/src/main/java/org/opensearch/sql/spark/dispatcher/IndexDMLHandler.java b/spark/src/main/java/org/opensearch/sql/spark/dispatcher/IndexDMLHandler.java
@@ -32,9 +32,9 @@
 import org.opensearch.sql.spark.flint.FlintIndexMetadata;
 import org.opensearch.sql.spark.flint.FlintIndexMetadataService;
 import org.opensearch.sql.spark.flint.operation.FlintIndexOp;
-import org.opensearch.sql.spark.flint.operation.FlintIndexOpVacuum;
 import org.opensearch.sql.spark.flint.operation.FlintIndexOpAlter;
 import org.opensearch.sql.spark.flint.operation.FlintIndexOpDrop;
+import org.opensearch.sql.spark.flint.operation.FlintIndexOpVacuum;
 import org.opensearch.sql.spark.response.JobExecutionResponseReader;
 
 /** Handle Index DML query. includes * DROP * ALT? */

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
@@ -8,13 +8,11 @@
 import static org.opensearch.sql.spark.execution.statestore.StateStore.DATASOURCE_TO_REQUEST_INDEX;
 import static org.opensearch.sql.spark.flint.FlintIndexState.ACTIVE;
 import static org.opensearch.sql.spark.flint.FlintIndexState.CANCELLING;
-import static org.opensearch.sql.spark.flint.FlintIndexState.CREATING;
 import static org.opensearch.sql.spark.flint.FlintIndexState.DELETED;
 import static org.opensearch.sql.spark.flint.FlintIndexState.DELETING;
 import static org.opensearch.sql.spark.flint.FlintIndexState.EMPTY;
 import static org.opensearch.sql.spark.flint.FlintIndexState.FAILED;
 import static org.opensearch.sql.spark.flint.FlintIndexState.REFRESHING;
-import static org.opensearch.sql.spark.flint.FlintIndexState.VACUUMING;
 import static org.opensearch.sql.spark.flint.FlintIndexType.COVERING;
 import static org.opensearch.sql.spark.flint.FlintIndexType.MATERIALIZED_VIEW;
 import static org.opensearch.sql.spark.flint.FlintIndexType.SKIPPING;

diff --git a/spark/src/test/java/org/opensearch/sql/spark/asyncquery/model/MockFlintSparkJob.java b/spark/src/test/java/org/opensearch/sql/spark/asyncquery/model/MockFlintSparkJob.java
@@ -40,8 +40,7 @@ public MockFlintSparkJob(StateStore stateStore, String latestId, String datasour
 
   public void transition(FlintIndexState newState) {
     stateModel =
-        StateStore.updateFlintIndexState(stateStore, datasource)
-            .apply(stateModel, newState);
+        StateStore.updateFlintIndexState(stateStore, datasource).apply(stateModel, newState);
   }
 
   public void refreshing() {