Skip to content

Commit 577ac6b

Browse files
authored
Address comments from PR6370 (#6371)
Signed-off-by: Krishna Kondaka <krishkdk@amazon.com>
1 parent 0ddc84b commit 577ac6b

1 file changed

Lines changed: 5 additions & 5 deletions

File tree

  • data-prepper-core/src/main/java/org/opensearch/dataprepper/core/pipeline/router

data-prepper-core/src/main/java/org/opensearch/dataprepper/core/pipeline/router/Router.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,8 @@
1010
import org.opensearch.dataprepper.model.record.Record;
1111

1212
import java.util.Collection;
13-
import java.util.HashMap;
1413
import java.util.HashSet;
14+
import java.util.LinkedHashMap;
1515
import java.util.Map;
1616
import java.util.Objects;
1717
import java.util.Set;
@@ -42,7 +42,7 @@ public <C> void route(
4242
Objects.requireNonNull(dataFlowComponents);
4343
Objects.requireNonNull(componentRecordsConsumer);
4444

45-
final Map<Object, Collection<Record>> componentRecords = new HashMap<>();
45+
final Map<C, Collection<Record>> componentRecords = new LinkedHashMap<>();
4646

4747
final Map<Record, Set<String>> recordsToRoutes = routeEventEvaluator.evaluateEventRoutes(allRecords);
4848

@@ -64,12 +64,12 @@ public <C> void route(
6464
recordsUnRouted.remove(record);
6565
}
6666
}
67-
componentRecords.put((C)component, records);
67+
componentRecords.put(component, records);
6868
});
6969
}
7070

71-
for (Map.Entry<Object, Collection<Record>> entry : componentRecords.entrySet()) {
72-
componentRecordsConsumer.accept((C)entry.getKey(), entry.getValue());
71+
for (Map.Entry<C, Collection<Record>> entry : componentRecords.entrySet()) {
72+
componentRecordsConsumer.accept(entry.getKey(), entry.getValue());
7373
}
7474

7575
if (recordsUnRouted != null) {

0 commit comments

Comments
 (0)