Test2

eliatra · Jul 9, 2024 · acfb938 · acfb938
1 parent 66f7833
commit acfb938
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 28 deletions.
diff --git a/core/src/main/java/org/opensearch/sql/planner/DefaultImplementor.java b/core/src/main/java/org/opensearch/sql/planner/DefaultImplementor.java
@@ -13,7 +13,6 @@
 import org.opensearch.sql.planner.logical.LogicalFetchCursor;
 import org.opensearch.sql.planner.logical.LogicalFilter;
 import org.opensearch.sql.planner.logical.LogicalLimit;
-import org.opensearch.sql.planner.logical.LogicalLookup;
 import org.opensearch.sql.planner.logical.LogicalNested;
 import org.opensearch.sql.planner.logical.LogicalPaginate;
 import org.opensearch.sql.planner.logical.LogicalPlan;
@@ -32,7 +31,6 @@
 import org.opensearch.sql.planner.physical.EvalOperator;
 import org.opensearch.sql.planner.physical.FilterOperator;
 import org.opensearch.sql.planner.physical.LimitOperator;
-import org.opensearch.sql.planner.physical.LookupOperator;
 import org.opensearch.sql.planner.physical.NestedOperator;
 import org.opensearch.sql.planner.physical.PhysicalPlan;
 import org.opensearch.sql.planner.physical.ProjectOperator;
@@ -76,19 +74,6 @@ public PhysicalPlan visitDedupe(LogicalDedupe node, C context) {
         node.getConsecutive());
   }
 
-  @Override
-  public PhysicalPlan visitLookup(LogicalLookup node, C context) {
-    return new LookupOperator(
-        visitChild(node, context),
-        node.getIndexName(),
-        node.getMatchFieldMap(),
-        node.getAppendOnly(),
-        node.getCopyFieldMap(),
-        (a, b) -> {
-          throw new UnsupportedOperationException("Lookup not implemented by DefaultImplementor");
-        });
-  }
-
   @Override
   public PhysicalPlan visitProject(LogicalProject node, C context) {
     return new ProjectOperator(

diff --git a/...n/java/org/opensearch/sql/opensearch/executor/protector/OpenSearchExecutionProtector.java b/...n/java/org/opensearch/sql/opensearch/executor/protector/OpenSearchExecutionProtector.java
@@ -31,13 +31,6 @@
 import org.opensearch.sql.planner.physical.WindowOperator;
 import org.opensearch.sql.storage.TableScanOperator;
 
-// [ant:jacocoReport] Rule violated for class
-// org.opensearch.sql.opensearch.executor.protector.OpenSearchExecutionProtector: lines covered
-// ratio is 0.6, but expected minimum is 1.0
-// [ant:jacocoReport] Rule violated for class
-// org.opensearch.sql.opensearch.executor.protector.OpenSearchExecutionProtector: branches covered
-// ratio is 0.2, but expected minimum is 1.0
-
 /** OpenSearch Execution Protector. */
 @RequiredArgsConstructor
 @AllArgsConstructor
@@ -134,12 +127,13 @@ public PhysicalPlan visitDedupe(DedupeOperator node, Object context) {
 
   @Override
   public PhysicalPlan visitLookup(LookupOperator node, Object context) {
-    return new LookupOperator(visitInput(node.getInput(), context),
-            node.getIndexName(),
-            node.getMatchFieldMap(),
-            node.getAppendOnly(),
-            node.getCopyFieldMap(),
-            node.getLookup());
+    return new LookupOperator(
+        visitInput(node.getInput(), context),
+        node.getIndexName(),
+        node.getMatchFieldMap(),
+        node.getAppendOnly(),
+        node.getCopyFieldMap(),
+        node.getLookup());
   }
 
   @Override