Reformat

Signed-off-by: Tomoyuki Morita <[email protected]>

spark/src/main/java/org/opensearch/sql/spark/dispatcher/BatchQueryHandler.java

@@ -29,9 +29,8 @@
 import org.opensearch.sql.spark.response.JobExecutionResponseReader;
 
 /**
- * The handler for batch query.
- * With batch query, queries are executed as single batch. The queries are sent along with job
- * execution request to spark.
+ * The handler for batch query. With batch query, queries are executed as single batch. The queries
+ * are sent along with job execution request to spark.
  */
 @RequiredArgsConstructor
 public class BatchQueryHandler extends AsyncQueryHandler {

spark/src/main/java/org/opensearch/sql/spark/dispatcher/IndexDMLHandler.java

@@ -32,10 +32,10 @@
 import org.opensearch.sql.spark.response.JobExecutionResponseReader;
 
 /**
- * The handler for Index DML (Data Manipulation Language) query.
- * Handles DROP/ALT/VACUUM operation for flint indices.
- * It will stop streaming query job as needed (e.g. when the flint index is automatically updated
- * by a streaming query, the streaming query is stopped when the index is dropped)
+ * The handler for Index DML (Data Manipulation Language) query. Handles DROP/ALT/VACUUM operation
+ * for flint indices. It will stop streaming query job as needed (e.g. when the flint index is
+ * automatically updated by a streaming query, the streaming query is stopped when the index is
+ * dropped)
  */
 @RequiredArgsConstructor
 public class IndexDMLHandler extends AsyncQueryHandler {

spark/src/main/java/org/opensearch/sql/spark/dispatcher/InteractiveQueryHandler.java

@@ -36,10 +36,10 @@
 import org.opensearch.sql.spark.response.JobExecutionResponseReader;
 
 /**
- * The handler for interactive query.
- * With interactive query, a session will be first established and then the session will be reused
- * for the following queries(statements). Session is an abstraction of spark job, and once the job
- * is started, the job will continuously poll the statements and execute query specified in it.
+ * The handler for interactive query. With interactive query, a session will be first established
+ * and then the session will be reused for the following queries(statements). Session is an
+ * abstraction of spark job, and once the job is started, the job will continuously poll the
+ * statements and execute query specified in it.
  */
 @RequiredArgsConstructor
 public class InteractiveQueryHandler extends AsyncQueryHandler {

spark/src/main/java/org/opensearch/sql/spark/dispatcher/RefreshQueryHandler.java

@@ -21,9 +21,8 @@
 import org.opensearch.sql.spark.response.JobExecutionResponseReader;
 
 /**
- * The handler for refresh query.
- * Refresh query is one time query request to refresh(update) flint index, and new job is submitted
- * to Spark.
+ * The handler for refresh query. Refresh query is one time query request to refresh(update) flint
+ * index, and new job is submitted to Spark.
  */
 public class RefreshQueryHandler extends BatchQueryHandler {
 

spark/src/main/java/org/opensearch/sql/spark/dispatcher/StreamingQueryHandler.java

@@ -27,8 +27,7 @@
 import org.opensearch.sql.spark.response.JobExecutionResponseReader;
 
 /**
- * The handler for streaming query.
- * Streaming query is a job to continuously update flint index.
+ * The handler for streaming query. Streaming query is a job to continuously update flint index.
  * Once started, the job can be stopped by IndexDML query.
  */
 public class StreamingQueryHandler extends BatchQueryHandler {

spark/src/main/java/org/opensearch/sql/spark/flint/IndexDMLResultStorageService.java

@@ -8,8 +8,7 @@
 import org.opensearch.sql.spark.dispatcher.model.IndexDMLResult;
 
 /**
- * Abstraction over the IndexDMLResult storage.
- * It stores the result of IndexDML query execution.
+ * Abstraction over the IndexDMLResult storage. It stores the result of IndexDML query execution.
  */
 public interface IndexDMLResultStorageService {
   IndexDMLResult createIndexDMLResult(IndexDMLResult result, String datasourceName);