Spotless Apply

Signed-off-by: Derek Ho <[email protected]>
opensearch-project · Sep 26, 2023 · fb2281e · fb2281e
1 parent 96f3ef0
commit fb2281e
Show file tree

Hide file tree

Showing 3 changed files with 28 additions and 28 deletions.
diff --git a/...rc/main/java/org/opensearch/sql/datasources/transport/CreateUpdateDatasourceResponse.java b/...rc/main/java/org/opensearch/sql/datasources/transport/CreateUpdateDatasourceResponse.java
@@ -2,12 +2,11 @@
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 
-public class CreateUpdateDatasourceResponse{
-    @JsonProperty("status")
-    private String status;
-
-    public CreateUpdateDatasourceResponse(String status) {
-        this.status = status;
-    }
+public class CreateUpdateDatasourceResponse {
+  @JsonProperty("status")
+  private String status;
 
+  public CreateUpdateDatasourceResponse(String status) {
+    this.status = status;
+  }
 }
diff --git a/...c/main/java/org/opensearch/sql/datasources/transport/TransportCreateDataSourceAction.java b/...c/main/java/org/opensearch/sql/datasources/transport/TransportCreateDataSourceAction.java
@@ -7,6 +7,8 @@
 
 package org.opensearch.sql.datasources.transport;
 
+import static org.opensearch.sql.protocol.response.format.JsonResponseFormatter.Style.PRETTY;
+
 import org.opensearch.action.ActionType;
 import org.opensearch.action.support.ActionFilters;
 import org.opensearch.action.support.HandledTransportAction;
@@ -17,13 +19,10 @@
 import org.opensearch.sql.datasources.model.transport.CreateDataSourceActionRequest;
 import org.opensearch.sql.datasources.model.transport.CreateDataSourceActionResponse;
 import org.opensearch.sql.datasources.service.DataSourceServiceImpl;
-import org.opensearch.sql.executor.ExecutionEngine;
 import org.opensearch.sql.protocol.response.format.JsonResponseFormatter;
 import org.opensearch.tasks.Task;
 import org.opensearch.transport.TransportService;
 
-import static org.opensearch.sql.protocol.response.format.JsonResponseFormatter.Style.PRETTY;
-
 public class TransportCreateDataSourceAction
     extends HandledTransportAction<CreateDataSourceActionRequest, CreateDataSourceActionResponse> {
   public static final String NAME = "cluster:admin/opensearch/ql/datasources/create";
@@ -61,14 +60,15 @@ protected void doExecute(
       DataSourceMetadata dataSourceMetadata = request.getDataSourceMetadata();
       dataSourceService.createDataSource(dataSourceMetadata);
       String responseContent =
-              new JsonResponseFormatter<CreateUpdateDatasourceResponse>(PRETTY) {
-                @Override
-                protected Object buildJsonObject(CreateUpdateDatasourceResponse response) {
-                  return response;
-                }
-              }.format(new CreateUpdateDatasourceResponse("Created DataSource with name " + dataSourceMetadata.getName()));
-      actionListener.onResponse(
-          new CreateDataSourceActionResponse(responseContent));
+          new JsonResponseFormatter<CreateUpdateDatasourceResponse>(PRETTY) {
+            @Override
+            protected Object buildJsonObject(CreateUpdateDatasourceResponse response) {
+              return response;
+            }
+          }.format(
+              new CreateUpdateDatasourceResponse(
+                  "Created DataSource with name " + dataSourceMetadata.getName()));
+      actionListener.onResponse(new CreateDataSourceActionResponse(responseContent));
     } catch (Exception e) {
       actionListener.onFailure(e);
     }

diff --git a/...c/main/java/org/opensearch/sql/datasources/transport/TransportUpdateDataSourceAction.java b/...c/main/java/org/opensearch/sql/datasources/transport/TransportUpdateDataSourceAction.java
@@ -7,6 +7,8 @@
 
 package org.opensearch.sql.datasources.transport;
 
+import static org.opensearch.sql.protocol.response.format.JsonResponseFormatter.Style.PRETTY;
+
 import org.opensearch.action.ActionType;
 import org.opensearch.action.support.ActionFilters;
 import org.opensearch.action.support.HandledTransportAction;
@@ -20,8 +22,6 @@
 import org.opensearch.tasks.Task;
 import org.opensearch.transport.TransportService;
 
-import static org.opensearch.sql.protocol.response.format.JsonResponseFormatter.Style.PRETTY;
-
 public class TransportUpdateDataSourceAction
     extends HandledTransportAction<UpdateDataSourceActionRequest, UpdateDataSourceActionResponse> {
 
@@ -59,14 +59,15 @@ protected void doExecute(
     try {
       dataSourceService.updateDataSource(request.getDataSourceMetadata());
       String responseContent =
-              new JsonResponseFormatter<CreateUpdateDatasourceResponse>(PRETTY) {
-                @Override
-                protected Object buildJsonObject(CreateUpdateDatasourceResponse response) {
-                  return response;
-                }
-              }.format(new CreateUpdateDatasourceResponse("Updated DataSource with name " +  request.getDataSourceMetadata().getName()));
-      actionListener.onResponse(
-          new UpdateDataSourceActionResponse(responseContent));
+          new JsonResponseFormatter<CreateUpdateDatasourceResponse>(PRETTY) {
+            @Override
+            protected Object buildJsonObject(CreateUpdateDatasourceResponse response) {
+              return response;
+            }
+          }.format(
+              new CreateUpdateDatasourceResponse(
+                  "Updated DataSource with name " + request.getDataSourceMetadata().getName()));
+      actionListener.onResponse(new UpdateDataSourceActionResponse(responseContent));
     } catch (Exception e) {
       actionListener.onFailure(e);
     }