End all files with new line

Signed-off-by: Mitchell Gale <[email protected]>

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/test/java/org/opensearch/sql/planner/logical/LogicalRelationTest.java

@@ -32,4 +32,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());
   }
-}
+}

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

@@ -49,4 +49,4 @@ void testConstructWithIllegalArguments() {
         () -> new SlidingWindowAssigner(1000, 0));
     assertEquals("Slide size [0] must be positive number", error2.getMessage());
   }
-}
+}

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

@@ -36,4 +36,4 @@ void testConstructWithIllegalWindowSize() {
         () -> new TumblingWindowAssigner(-1));
     assertEquals("Window size [-1] must be positive number", error.getMessage());
   }
-}
+}

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

@@ -31,4 +31,4 @@ void shouldFireWindowBelowWatermark() {
     assertEquals(TriggerResult.FIRE, trigger.trigger(new Window(500, 800)));
     assertEquals(TriggerResult.FIRE, trigger.trigger(new Window(500, 1000)));
   }
-}
+}

core/src/test/java/org/opensearch/sql/storage/write/TableWriteOperatorTest.java

@@ -67,4 +67,4 @@ public Boolean visitTableWrite(TableWriteOperator node, Object context) {
   void testGetChild() {
     assertEquals(Collections.singletonList(child), tableWrite.getChild());
   }
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/encryptor/Encryptor.java

@@ -25,4 +25,4 @@ public interface Encryptor {
    */
   String decrypt(String encryptedText);
 
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/encryptor/EncryptorImpl.java

@@ -52,4 +52,4 @@ public String decrypt(String encryptedText) {
     return new String(decryptedResult.getResult());
   }
 
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/model/transport/CreateDataSourceActionRequest.java

@@ -46,4 +46,4 @@ public ActionRequestValidationException validate() {
       return null;
     }
   }
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/model/transport/CreateDataSourceActionResponse.java

@@ -30,4 +30,4 @@ public CreateDataSourceActionResponse(StreamInput in) throws IOException {
   public void writeTo(StreamOutput streamOutput) throws IOException {
     streamOutput.writeString(result);
   }
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/model/transport/DeleteDataSourceActionRequest.java

@@ -48,4 +48,4 @@ public ActionRequestValidationException validate() {
     }
   }
 
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/model/transport/DeleteDataSourceActionResponse.java

@@ -30,4 +30,4 @@ public void writeTo(StreamOutput streamOutput) throws IOException {
     streamOutput.writeString(result);
   }
 
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/model/transport/GetDataSourceActionRequest.java

@@ -46,4 +46,4 @@ public ActionRequestValidationException validate() {
     }
   }
 
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/model/transport/GetDataSourceActionResponse.java

@@ -30,4 +30,4 @@ public void writeTo(StreamOutput streamOutput) throws IOException {
     streamOutput.writeString(result);
   }
 
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/model/transport/UpdateDataSourceActionRequest.java

@@ -44,4 +44,4 @@ public ActionRequestValidationException validate() {
       return null;
     }
   }
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/model/transport/UpdateDataSourceActionResponse.java

@@ -30,4 +30,4 @@ public UpdateDataSourceActionResponse(StreamInput in) throws IOException {
   public void writeTo(StreamOutput streamOutput) throws IOException {
     streamOutput.writeString(result);
   }
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/rest/RestDataSourceQueryAction.java

@@ -250,4 +250,4 @@ private static boolean isClientError(Exception e) {
         || e instanceof IllegalArgumentException;
   }
 
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/service/DataSourceMetadataStorage.java

@@ -60,4 +60,4 @@ public interface DataSourceMetadataStorage {
    */
   void deleteDataSourceMetadata(String datasourceName);
 
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/transport/TransportCreateDataSourceAction.java

@@ -57,4 +57,4 @@ protected void doExecute(Task task, CreateDataSourceActionRequest request,
     }
   }
 
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/transport/TransportDeleteDataSourceAction.java

@@ -56,4 +56,4 @@ protected void doExecute(Task task, DeleteDataSourceActionRequest request,
     }
   }
 
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/transport/TransportGetDataSourceAction.java

@@ -92,4 +92,4 @@ protected Object buildJsonObject(DataSourceMetadata response) {
     }.format(dataSourceMetadata);
     return responseContent;
   }
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/transport/TransportUpdateDataSourceAction.java

@@ -56,4 +56,4 @@ protected void doExecute(Task task, UpdateDataSourceActionRequest request,
     }
   }
 
-}
+}

datasources/src/main/java/org/opensearch/sql/datasources/utils/Scheduler.java

@@ -30,4 +30,4 @@ private static Runnable withCurrentContext(final Runnable task) {
       task.run();
     };
   }
-}
+}

datasources/src/test/java/org/opensearch/sql/datasources/encryptor/EncryptorImplTest.java

@@ -84,4 +84,4 @@ public void testDecryptWithDifferentKey() {
       encryptor2.decrypt(encrypted);
     });
   }
-}
+}

datasources/src/test/java/org/opensearch/sql/datasources/transport/TransportCreateDataSourceActionTest.java

@@ -83,4 +83,4 @@ public void testDoExecuteWithException() {
     Assertions.assertEquals("Error",
         exception.getMessage());
   }
-}
+}

datasources/src/test/java/org/opensearch/sql/datasources/transport/TransportDeleteDataSourceActionTest.java

@@ -75,4 +75,4 @@ public void testDoExecuteWithException() {
     Assertions.assertEquals("Error",
         exception.getMessage());
   }
-}
+}

datasources/src/test/java/org/opensearch/sql/datasources/transport/TransportGetDataSourceActionTest.java

@@ -134,4 +134,4 @@ public void testDoExecuteWithException() {
     Assertions.assertEquals("Error",
         exception.getMessage());
   }
-}
+}

datasources/src/test/java/org/opensearch/sql/datasources/transport/TransportUpdateDataSourceActionTest.java

@@ -84,4 +84,4 @@ public void testDoExecuteWithException() {
     Assertions.assertEquals("Error",
         exception.getMessage());
   }
-}
+}

datasources/src/test/java/org/opensearch/sql/datasources/utils/SchedulerTest.java

@@ -42,4 +42,4 @@ public void testSchedule() {
     Assert.assertTrue(isRun.get());
   }
 
-}
+}

legacy/src/test/java/org/opensearch/sql/legacy/antlr/semantic/SemanticAnalyzerBasicTest.java

@@ -594,4 +594,4 @@ public void fieldWithSpacesInNameShouldPass() {
         Assert.assertSame(TEXT, type.get());
     }
 
-}
+}

legacy/src/test/java/org/opensearch/sql/legacy/query/planner/physical/node/scroll/SearchHitRowTest.java

@@ -62,4 +62,4 @@ public void testRetainWithUnexpandedObjectField() {
     expected.sourceRef(new BytesArray("{\"a.attributes.hardware.correlate_id\": 10}"));
     assertEquals(expected, row.data());
   }
-}
+}

prometheus/src/main/java/org/opensearch/sql/prometheus/client/PrometheusClientImpl.java

@@ -112,4 +112,4 @@ private JSONObject readResponse(Response response) throws IOException {
   }
 
 
-}
+}

prometheus/src/main/java/org/opensearch/sql/prometheus/functions/response/QueryRangeFunctionResponseHandle.java

@@ -28,4 +28,4 @@ public interface QueryRangeFunctionResponseHandle {
    * Return ExecutionEngine.Schema of the Prometheus response.
    */
   ExecutionEngine.Schema schema();
-}
+}

prometheus/src/main/java/org/opensearch/sql/prometheus/storage/PrometheusMetricTable.java

@@ -119,4 +119,4 @@ public TableScanBuilder createScanBuilder() {
       return null;
     }
   }
-}
+}

prometheus/src/main/java/org/opensearch/sql/prometheus/storage/implementor/PrometheusDefaultImplementor.java

@@ -137,4 +137,4 @@ private Optional<NamedExpression> getSpanExpression(List<NamedExpression> namedE
   }
 
 
-}
+}

prometheus/src/main/java/org/opensearch/sql/prometheus/storage/querybuilder/StepParameterResolver.java

@@ -60,4 +60,4 @@ private static Optional<SpanExpression> getSpanExpression(
 
 
 
-}
+}