Removed unused imports

Signed-off-by:Marcos Gonzalez Mayedo <[email protected]> Signed-off-by: Marcos Gonzalez Mayedo <[email protected]>
opensearch-project · Jul 25, 2023 · 53086c4 · 53086c4
1 parent 5971190
commit 53086c4
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 4 deletions.
diff --git a/...main/java/org/opensearch/dataprepper/plugins/sink/client/CloudWatchLogsClientFactory.java b/...main/java/org/opensearch/dataprepper/plugins/sink/client/CloudWatchLogsClientFactory.java
@@ -10,7 +10,6 @@
 import org.opensearch.dataprepper.plugins.sink.config.AwsConfig;
 import software.amazon.awssdk.auth.credentials.AwsCredentialsProvider;
 import software.amazon.awssdk.core.client.config.ClientOverrideConfiguration;
-import software.amazon.awssdk.core.retry.RetryPolicy;
 import software.amazon.awssdk.services.cloudwatchlogs.CloudWatchLogsClient;
 
 /**

diff --git a/...rc/main/java/org/opensearch/dataprepper/plugins/sink/client/CloudWatchLogsDispatcher.java b/...rc/main/java/org/opensearch/dataprepper/plugins/sink/client/CloudWatchLogsDispatcher.java
@@ -7,7 +7,6 @@
 
 import lombok.Builder;
 import org.opensearch.dataprepper.model.event.EventHandle;
-import org.opensearch.dataprepper.model.event.JacksonEvent;
 import org.opensearch.dataprepper.plugins.sink.packaging.ThreadTaskEvents;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -65,7 +64,7 @@ private List<InputLogEvent> prepareInputLogEvents(final ThreadTaskEvents eventDa
     /**
      * Flush function to handle the flushing of logs to CloudWatchLogs services;
      * @param inputLogEvents Collection of inputLogEvents to be flushed
-     * @return true if successful, false otherwise
+     * @param eventHandles Collection of EventHandles for events
      */
     public void dispatchLogs(List<InputLogEvent> inputLogEvents, Collection<EventHandle> eventHandles) {
         boolean failedPost = true;

diff --git a/...s/src/main/java/org/opensearch/dataprepper/plugins/sink/client/CloudWatchLogsService.java b/...s/src/main/java/org/opensearch/dataprepper/plugins/sink/client/CloudWatchLogsService.java
@@ -25,6 +25,14 @@
 
 import static java.util.concurrent.Executors.newCachedThreadPool; //TODO: Can implement a more strict pooling method if needed.
 
+/**
+ * CloudWatchLogs Service encapsulates the log processing step.
+ * It accomplishes this by:
+ * 1. Reading in log events.
+ * 2. Buffering data.
+ * 3. Checking for limit conditions.
+ * 4. Making PLE calls to CloudWatchLogs.
+ */
 public class CloudWatchLogsService {
     private static final Logger LOG = LoggerFactory.getLogger(CloudWatchLogsService.class);
     private final CloudWatchLogsClient cloudWatchLogsClient;

diff --git a/...c/test/java/org/opensearch/dataprepper/plugins/sink/client/CloudWatchLogsServiceTest.java b/...c/test/java/org/opensearch/dataprepper/plugins/sink/client/CloudWatchLogsServiceTest.java
@@ -7,7 +7,6 @@
 
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
-import org.mockito.MockedStatic;
 import org.opensearch.dataprepper.model.event.Event;
 import org.opensearch.dataprepper.model.event.EventHandle;
 import org.opensearch.dataprepper.model.event.JacksonEvent;