Simplify Analyzer implementation

Signed-off-by: currantw <[email protected]>
Bit-Quill · Feb 3, 2025 · 5bb0617 · 5bb0617
1 parent bf49974
commit 5bb0617
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/core/src/main/java/org/opensearch/sql/analysis/Analyzer.java b/core/src/main/java/org/opensearch/sql/analysis/Analyzer.java
@@ -464,7 +464,6 @@ public LogicalPlan visitFlatten(Flatten node, AnalysisContext context) {
     ReferenceExpression fieldExpr =
         (ReferenceExpression) expressionAnalyzer.analyze(node.getField(), context);
     String fieldName = fieldExpr.getAttr();
-    ExprType fieldType = fieldExpr.type();
 
     // [A] Determine fields to add
     // ---------------------------
@@ -545,7 +544,7 @@ public LogicalPlan visitFlatten(Flatten node, AnalysisContext context) {
       env.define(DSL.ref(name, type));
     }
 
-    return new LogicalFlatten(child, DSL.ref(fieldName, STRUCT));
+    return new LogicalFlatten(child, fieldExpr);
   }
 
   /** Build {@link ParseExpression} to context and skip to child nodes. */