From f4723f75654a294bd6223d4f9075ace94bb5a9b5 Mon Sep 17 00:00:00 2001 From: Kadin Rabo Date: Fri, 4 Oct 2024 11:12:49 -0400 Subject: [PATCH] chore: comment --- core/src/main/java/io/substrait/relation/Set.java | 2 +- .../java/io/substrait/isthmus/SubstraitRelNodeConverter.java | 3 +-- isthmus/src/test/java/io/substrait/isthmus/utils/SetUtils.java | 2 +- 3 files changed, 3 insertions(+), 4 deletions(-) diff --git a/core/src/main/java/io/substrait/relation/Set.java b/core/src/main/java/io/substrait/relation/Set.java index 9b1f9992..2ddb2485 100644 --- a/core/src/main/java/io/substrait/relation/Set.java +++ b/core/src/main/java/io/substrait/relation/Set.java @@ -8,7 +8,7 @@ public abstract class Set extends AbstractRel implements HasExtension { public abstract Set.SetOp getSetOp(); - // MINUS_MULTISET and INTERSECTION_PRIMARY are set to be removed (substrait-io/substrait/pull/708) + // MINUS_MULTISET and INTERSECTION_PRIMARY mappings are set to be removed due to no direct SQL mapping (substrait-io/substrait/pull/708) public static enum SetOp { UNKNOWN(SetRel.SetOp.SET_OP_UNSPECIFIED), MINUS_PRIMARY(SetRel.SetOp.SET_OP_MINUS_PRIMARY), diff --git a/isthmus/src/main/java/io/substrait/isthmus/SubstraitRelNodeConverter.java b/isthmus/src/main/java/io/substrait/isthmus/SubstraitRelNodeConverter.java index da2b8311..8b75ebcd 100644 --- a/isthmus/src/main/java/io/substrait/isthmus/SubstraitRelNodeConverter.java +++ b/isthmus/src/main/java/io/substrait/isthmus/SubstraitRelNodeConverter.java @@ -211,8 +211,7 @@ public RelNode visit(Set set) throws RuntimeException { input -> { relBuilder.push(input.accept(this)); }); - // MINUS_MULTISET and INTERSECTION_PRIMARY are set to be removed - // (substrait-io/substrait/pull/708) + // MINUS_MULTISET and INTERSECTION_PRIMARY mappings are set to be removed due to no direct SQL mapping (substrait-io/substrait/pull/708) var builder = switch (set.getSetOp()) { case MINUS_PRIMARY -> relBuilder.minus(false, numInputs); diff --git a/isthmus/src/test/java/io/substrait/isthmus/utils/SetUtils.java b/isthmus/src/test/java/io/substrait/isthmus/utils/SetUtils.java index 15a0603d..7c64a7f7 100644 --- a/isthmus/src/test/java/io/substrait/isthmus/utils/SetUtils.java +++ b/isthmus/src/test/java/io/substrait/isthmus/utils/SetUtils.java @@ -50,7 +50,7 @@ public static String getSetQuery(Set.SetOp op, boolean multi) { } // Generate all combinations excluding the UNKNOWN operator - // MINUS_MULTISET and INTERSECTION_PRIMARY are set to be removed (substrait-io/substrait/pull/708) + // Note: MINUS_MULTISET and INTERSECTION_PRIMARY mappings to Calcite are set to be removed due to no direct SQL mapping (substrait-io/substrait/pull/708) public static Stream setTestConfig() { return Arrays.stream(Set.SetOp.values()) .filter(