From 47ada91ddb0e7fe0a36182934ac0559bd28df03d Mon Sep 17 00:00:00 2001 From: Krishna Kondaka Date: Thu, 19 Dec 2024 23:51:03 +0000 Subject: [PATCH] Removed unnecessary API Signed-off-by: Krishna Kondaka --- .../plugins/processor/aggregate/AggregateGroupManager.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/data-prepper-plugins/aggregate-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/aggregate/AggregateGroupManager.java b/data-prepper-plugins/aggregate-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/aggregate/AggregateGroupManager.java index d5dd324762..1b67eb7557 100644 --- a/data-prepper-plugins/aggregate-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/aggregate/AggregateGroupManager.java +++ b/data-prepper-plugins/aggregate-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/aggregate/AggregateGroupManager.java @@ -27,11 +27,6 @@ AggregateGroup getAggregateGroup(final IdentificationKeysHasher.IdentificationKe return allGroups.computeIfAbsent(identificationKeysMap, (hash) -> new AggregateGroup(identificationKeysMap.getKeyMap())); } - AggregateGroup getAggregateGroupForEvent(final IdentificationKeysHasher.IdentificationKeysMap identificationKeysMap, final Event event) { - AggregateGroup aggregateGroup = getAggregateGroup(identificationKeysMap); - aggregateGroup.attachToEventAcknowledgementSet(event); - return aggregateGroup; - } List> getGroupsToConclude(final boolean forceConclude) { final List> groupsToConclude = new ArrayList<>();