Skip to content

Commit

Permalink
Translate proc optimizations (#4824)
Browse files Browse the repository at this point in the history
* dplive1.yaml

Signed-off-by: Krishna Kondaka <krishkdk@dev-dsk-krishkdk-2c-bd29c437.us-west-2.amazon.com>

* Delete .github/workflows/static.yml

Signed-off-by: Krishna Kondaka <krishkdk@dev-dsk-krishkdk-2c-bd29c437.us-west-2.amazon.com>

* Optimize translateSource in translate processor

Signed-off-by: Krishna Kondaka <krishkdk@dev-dsk-krishkdk-2c-bd29c437.us-west-2.amazon.com>

* Addressed review comments

Signed-off-by: Krishna Kondaka <krishkdk@dev-dsk-krishkdk-2c-bd29c437.us-west-2.amazon.com>

---------

Signed-off-by: Krishna Kondaka <krishkdk@dev-dsk-krishkdk-2c-bd29c437.us-west-2.amazon.com>
Co-authored-by: Krishna Kondaka <krishkdk@dev-dsk-krishkdk-2c-bd29c437.us-west-2.amazon.com>
  • Loading branch information
kkondaka and Krishna Kondaka committed Aug 15, 2024
1 parent 91b6666 commit 72e2db7
Showing 1 changed file with 4 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -89,9 +89,8 @@ private List<String> getSourceKeys(Object sourceObject){
}

private void translateSource(Object sourceObject, Event recordEvent, TargetsParameterConfig targetConfig) {
Map<String, Object> recordObject = recordEvent.toMap();
List<String> sourceKeysPaths = getSourceKeys(sourceObject);
if(Objects.isNull(recordObject) || sourceKeysPaths.isEmpty()){
if(sourceKeysPaths.isEmpty()){
return;
}

Expand All @@ -107,14 +106,14 @@ private void translateSource(Object sourceObject, Event recordEvent, TargetsPara
}

String rootField = jsonExtractor.getRootField(commonPath);
if(!recordObject.containsKey(rootField)){
if (!recordEvent.containsKey(rootField)) {
return;
}

Map<String, Object> recordObject = recordEvent.toMap();
List<Object> targetObjects = jsonExtractor.getObjectFromPath(commonPath, recordObject);
if(!targetObjects.isEmpty()) {
targetObjects.forEach(targetObj -> performMappings(targetObj, sourceKeys, sourceObject, targetConfig));
recordEvent.put(rootField, recordObject.get(rootField));
recordEvent.put(rootField,recordObject.get(rootField));
}
}

Expand Down

0 comments on commit 72e2db7

Please sign in to comment.