-
Notifications
You must be signed in to change notification settings - Fork 237
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add AttributeRebuilder for enriching return types when reducing type …
…metadata
- Loading branch information
1 parent
0e1f2f3
commit c86e590
Showing
11 changed files
with
919 additions
and
10 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
124 changes: 124 additions & 0 deletions
124
warehouse/query-core/src/main/java/datawave/query/util/transformer/AttributeRebuilder.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,124 @@ | ||
| package datawave.query.util.transformer; | ||
|
|
||
| import java.util.HashMap; | ||
| import java.util.Map; | ||
| import java.util.Set; | ||
|
|
||
| import javax.annotation.Nullable; | ||
|
|
||
| import org.apache.log4j.Logger; | ||
|
|
||
| import datawave.data.type.Type; | ||
| import datawave.query.attributes.Attribute; | ||
| import datawave.query.attributes.TypeAttribute; | ||
| import datawave.query.jexl.JexlASTHelper; | ||
| import datawave.query.model.QueryModel; | ||
| import datawave.query.util.TypeMetadata; | ||
|
|
||
| /** | ||
| * Utility class that handles rebuilding a basic NoOp attribute into an attribute of the correct type, given TypeMetadata and optionally a QueryModel | ||
| */ | ||
| public class AttributeRebuilder { | ||
| private static final Logger log = Logger.getLogger(AttributeRebuilder.class); | ||
| private final TypeMetadata typeMetadata; | ||
| private final Map<String,String> fieldMap; | ||
| private final Map<String,Class<?>> classCache; | ||
|
|
||
| /** | ||
| * Main constructor for the rebuilder, QueryModel may be null | ||
| * | ||
| * @param typeMetadata | ||
| * @param queryModel | ||
| */ | ||
| public AttributeRebuilder(TypeMetadata typeMetadata, @Nullable QueryModel queryModel) { | ||
| this.typeMetadata = typeMetadata; | ||
| if (queryModel == null) { | ||
| this.fieldMap = new HashMap<>(); | ||
| } else { | ||
| this.fieldMap = invertMap(queryModel.getReverseQueryMapping()); | ||
| } | ||
| this.classCache = new HashMap<>(); | ||
| } | ||
|
|
||
| private Map<String,String> invertMap(Map<String,String> map) { | ||
| Map<String,String> mappings = new HashMap<>(); | ||
| for (Map.Entry<String,String> entry : map.entrySet()) { | ||
| mappings.put(entry.getValue(), entry.getKey()); | ||
| } | ||
| return mappings; | ||
| } | ||
|
|
||
| /** | ||
| * Given a field and an attribute, return the correctly typed attribute | ||
| * | ||
| * @param field | ||
| * the field | ||
| * @param attr | ||
| * the attribute | ||
| * @return an attribute of the correct type | ||
| */ | ||
| public Attribute rebuild(String field, Attribute<?> attr) { | ||
| field = JexlASTHelper.deconstructIdentifier(field); | ||
| Set<String> normalizerNames = typeMetadata.getNormalizerNamesForField(field); | ||
|
|
||
| if (normalizerNames.isEmpty()) { | ||
| populateNormalizerFromQueryModel(field, normalizerNames); | ||
| } | ||
|
|
||
| if (normalizerNames.size() > 1 && log.isTraceEnabled()) { | ||
| log.trace("Found " + normalizerNames.size() + " normalizers for field " + field + ", using first normalizer"); | ||
| } | ||
|
|
||
| for (String name : normalizerNames) { | ||
| try { | ||
| Class<?> clazz = getClass(name); | ||
| Type<?> type = (Type<?>) clazz.getDeclaredConstructor().newInstance(); | ||
|
|
||
| type.setDelegateFromString(String.valueOf(attr.getData())); | ||
| return new TypeAttribute<>(type, attr.getMetadata(), attr.isToKeep()); | ||
| } catch (Exception e) { | ||
| throw new RuntimeException(e); | ||
| } | ||
| } | ||
|
|
||
| return attr; | ||
| } | ||
|
|
||
| /** | ||
| * Populate normalizer names from the query model | ||
| * | ||
| * @param field | ||
| * the field | ||
| * @param normalizerNames | ||
| * the set of normalizer names | ||
| */ | ||
| private void populateNormalizerFromQueryModel(String field, Set<String> normalizerNames) { | ||
| if (log.isTraceEnabled()) { | ||
| log.trace("Field " + field + " not found in TypeMetadata, falling back to QueryModel"); | ||
| } | ||
|
|
||
| String alias = fieldMap.get(field); | ||
| if (alias == null) { | ||
| log.error("Field " + field + " did not have a reverse mapping in the query model"); | ||
| } | ||
|
|
||
| normalizerNames.addAll(typeMetadata.getNormalizerNamesForField(alias)); | ||
| } | ||
|
|
||
| /** | ||
| * Get the class for the provided name | ||
| * | ||
| * @param name | ||
| * the name | ||
| * @return a class | ||
| */ | ||
| private Class<?> getClass(String name) { | ||
| return classCache.computeIfAbsent(name, className -> { | ||
| try { | ||
| return Class.forName(className); | ||
| } catch (ClassNotFoundException e) { | ||
| throw new RuntimeException(e); | ||
| } | ||
| }); | ||
| } | ||
| } |
Oops, something went wrong.