From 101cfedba95d1a1da5620030d57b949adb8256a5 Mon Sep 17 00:00:00 2001 From: srigovs Date: Tue, 20 Feb 2024 15:22:04 -0800 Subject: [PATCH] Add support for spilt event processor(#4089) Signed-off-by: srigovs --- .../processor/splitevent/SplitEventProcessor.java | 2 -- .../processor/splitevent/SplitEventProcessorTest.java | 11 +++++++---- 2 files changed, 7 insertions(+), 6 deletions(-) diff --git a/data-prepper-plugins/split-event-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/splitevent/SplitEventProcessor.java b/data-prepper-plugins/split-event-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/splitevent/SplitEventProcessor.java index f304cd5f3a..9c41943010 100644 --- a/data-prepper-plugins/split-event-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/splitevent/SplitEventProcessor.java +++ b/data-prepper-plugins/split-event-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/splitevent/SplitEventProcessor.java @@ -22,8 +22,6 @@ import java.util.ArrayList; import java.util.Collection; -import java.util.HashMap; -import java.util.Map; import java.util.regex.Pattern; diff --git a/data-prepper-plugins/split-event-processor/src/test/java/org/opensearch/dataprepper/plugins/processor/splitevent/SplitEventProcessorTest.java b/data-prepper-plugins/split-event-processor/src/test/java/org/opensearch/dataprepper/plugins/processor/splitevent/SplitEventProcessorTest.java index fcbd6ee527..8d1f14999e 100644 --- a/data-prepper-plugins/split-event-processor/src/test/java/org/opensearch/dataprepper/plugins/processor/splitevent/SplitEventProcessorTest.java +++ b/data-prepper-plugins/split-event-processor/src/test/java/org/opensearch/dataprepper/plugins/processor/splitevent/SplitEventProcessorTest.java @@ -17,11 +17,7 @@ import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.provider.Arguments; import org.junit.jupiter.params.provider.MethodSource; -import static org.mockito.ArgumentMatchers.any; import org.mockito.Mock; -import static org.mockito.Mockito.atLeast; -import static org.mockito.Mockito.atLeastOnce; -import static org.mockito.Mockito.spy; import org.mockito.junit.jupiter.MockitoExtension; import org.opensearch.dataprepper.metrics.PluginMetrics; import org.opensearch.dataprepper.model.acknowledgements.AcknowledgementSet; @@ -44,6 +40,13 @@ import static org.junit.jupiter.api.Assertions.assertTrue; import static org.hamcrest.Matchers.equalTo; import static org.mockito.Mockito.mock; +<<<<<<< HEAD +======= +<<<<<<< HEAD +======= +import static org.mockito.Mockito.spy; +>>>>>>> 69f6a5f24 (Add support for spilt event processor) +>>>>>>> cbca931a8 (Add support for spilt event processor) import static org.mockito.Mockito.when; import static org.mockito.Mockito.verify;