From acfb938dafdeb233d5707b6fa4220197e804d6b2 Mon Sep 17 00:00:00 2001 From: Hendrik Saly Date: Tue, 9 Jul 2024 16:36:02 +0200 Subject: [PATCH] Test2 --- .../sql/planner/DefaultImplementor.java | 15 -------------- .../OpenSearchExecutionProtector.java | 20 +++++++------------ 2 files changed, 7 insertions(+), 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 index 6d19bb312f..b53d17b38f 100644 --- 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/opensearch/src/main/java/org/opensearch/sql/opensearch/executor/protector/OpenSearchExecutionProtector.java b/opensearch/src/main/java/org/opensearch/sql/opensearch/executor/protector/OpenSearchExecutionProtector.java index f57cd9cab9..01427a4ba0 100644 --- a/opensearch/src/main/java/org/opensearch/sql/opensearch/executor/protector/OpenSearchExecutionProtector.java +++ b/opensearch/src/main/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