Skip to content

Commit

Permalink
Revert back to call parse map config for each call separately
Browse files Browse the repository at this point in the history
Signed-off-by: Martin Gaievski <[email protected]>
  • Loading branch information
martin-gaievski committed Jul 9, 2024
1 parent 7a3a8b2 commit 0f2638d
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,6 @@ public abstract class InferenceProcessor extends AbstractProcessor {

private final Environment environment;
private final ClusterService clusterService;
List<Pair<String, Object>> mappingForNestedFields;

public InferenceProcessor(
String tag,
Expand All @@ -88,7 +87,6 @@ public InferenceProcessor(
this.mlCommonsClientAccessor = clientAccessor;
this.environment = environment;
this.clusterService = clusterService;
mappingForNestedFields = fieldMap.entrySet().stream().map(this::processNestedKey).collect(Collectors.toList());
}

private void validateEmbeddingConfiguration(Map<String, Object> fieldMap) {
Expand Down Expand Up @@ -284,7 +282,8 @@ private void createInferenceListForMapTypeInput(Object sourceValue, List<String>
Map<String, Object> buildMapWithTargetKeys(IngestDocument ingestDocument) {
Map<String, Object> sourceAndMetadataMap = ingestDocument.getSourceAndMetadata();
Map<String, Object> mapWithProcessorKeys = new LinkedHashMap<>();
for (Pair<String, Object> processedNestedKey : mappingForNestedFields) {
for (Map.Entry<String, Object> fieldMapEntry : fieldMap.entrySet()) {
Pair<String, Object> processedNestedKey = processNestedKey(fieldMapEntry);
String originalKey = processedNestedKey.getKey();
Object targetKey = processedNestedKey.getValue();

Expand Down

0 comments on commit 0f2638d

Please sign in to comment.