Renamed the API

Signed-off-by: Krishna Kondaka <[email protected]>
opensearch-project · Nov 8, 2023 · dc1cc77 · dc1cc77
1 parent dcab048
commit dc1cc77
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...to-common/src/main/java/org/opensearch/dataprepper/plugins/otel/codec/OTelProtoCodec.java b/...to-common/src/main/java/org/opensearch/dataprepper/plugins/otel/codec/OTelProtoCodec.java
@@ -152,7 +152,7 @@ public List<Span> parseExportTraceServiceRequest(final ExportTraceServiceRequest
                     .flatMap(rs -> parseResourceSpans(rs).stream()).collect(Collectors.toList());
         }
 
-        public Map<String, ExportTraceServiceRequest> splitExportTraceServiceRequest(final ExportTraceServiceRequest exportTraceServiceRequest) {
+        public Map<String, ExportTraceServiceRequest> splitExportTraceServiceRequestByTraceId(final ExportTraceServiceRequest exportTraceServiceRequest) {
             Map<String, ExportTraceServiceRequest> result = new HashMap<>();
             for (final ResourceSpans resourceSpans: exportTraceServiceRequest.getResourceSpansList()) {
                 Map<String, ResourceSpans> out = splitResourceSpans(resourceSpans);

diff --git a/...ommon/src/test/java/org/opensearch/dataprepper/plugins/otel/codec/OTelProtoCodecTest.java b/...ommon/src/test/java/org/opensearch/dataprepper/plugins/otel/codec/OTelProtoCodecTest.java
@@ -143,7 +143,7 @@ class OTelProtoDecoderTest {
         @Test
         public void testSplitExportTraceServiceRequestWithMultipleTraces() throws Exception {
             final ExportTraceServiceRequest exportTraceServiceRequest = buildExportTraceServiceRequestFromJsonFile(TEST_REQUEST_MULTIPLE_TRACES_FILE);
-            final Map<String, ExportTraceServiceRequest> map = decoderUnderTest.splitExportTraceServiceRequest(exportTraceServiceRequest);
+            final Map<String, ExportTraceServiceRequest> map = decoderUnderTest.splitExportTraceServiceRequestByTraceId(exportTraceServiceRequest);
             assertThat(map.size(), is(equalTo(3)));
             for (Map.Entry<String, ExportTraceServiceRequest> entry: map.entrySet()) {
                 String expectedTraceId = new String(Hex.decodeHex(entry.getKey()), StandardCharsets.UTF_8);