Github user kkhatua commented on a diff in the pull request:
https://github.com/apache/drill/pull/1116#discussion_r167649909
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/server/rest/profile/ProfileWrapper.java
---
@@ -322,4 +330,16 @@ public String getOperatorsJSON() {
public boolean isOnlyImpersonationEnabled() {
return onlyImpersonationEnabled;
}
+
+ //Generates operator names inferred from physical plan
+ private void generateOpMap(String plan) {
+ this.physicalOperatorMap = new HashMap<String,String>();
+ String[] operatorLine = plan.split("\\n");
+ for (String line : operatorLine) {
+ String[] lineToken = line.split("\\s+", 3);
+ String operatorPath = lineToken[0].trim().replaceFirst("-", "-xx-");
//Required format for lookup
--- End diff --
Added the following as the example
```
01-03 Flatten(flattenField=[$1]) : rowType = RecordType(ANY rfsSpecCode, ...
```
---
