lowka commented on code in PR #6374:
URL: https://github.com/apache/ignite-3/pull/6374#discussion_r2269363924
##########
modules/sql-engine/src/test/resources/mapping/test_partition_pruning.test:
##########
@@ -360,3 +389,92 @@ Fragment#3 correlated
projection: [true]
est: (rows=1)
---
+
+N0
+SELECT id, c1 FROM (SELECT id, c1 FROM t1_n1n2n3 EXCEPT ALL SELECT id, c1 FROM
t1_n1n2n3 WHERE id IN (1, 1, 3, 3)) tmp ORDER BY id ASC
+---
+Fragment#2 root
+ distribution: single
+ executionNodes: [N0]
+ exchangeSourceNodes: {3=[N1, N2, N3]}
+ colocationGroup[-1]: {nodes=[N0], sourceIds=[-1, 3], assignments={},
partitionsWithConsistencyTokens={N0=[]}}
+ colocationGroup[3]: {nodes=[N0], sourceIds=[-1, 3], assignments={},
partitionsWithConsistencyTokens={N0=[]}}
+ tree:
+ Receiver
+ fieldNames: [ID, C1]
+ sourceFragmentId: 3
+ est: (rows=1)
+
+Fragment#3
+ distribution: table PUBLIC.T1_N1N2N3 in zone ZONE_1
+ executionNodes: [N1, N2, N3]
+ targetNodes: [N0]
+ colocationGroup[0]: {nodes=[N1, N2, N3], sourceIds=[0],
assignments={part_0=N1:3, part_1=N2:3, part_2=N3:3},
partitionsWithConsistencyTokens={N1=[part_0:3], N2=[part_1:3], N3=[part_2:3]}}
+ colocationGroup[1]: {nodes=[N2], sourceIds=[1], assignments={part_1=N2:3},
partitionsWithConsistencyTokens={N2=[part_1:3]}}
+ partitions: [T1_N1N2N3=[N1={0}, N2={1}, N3={2}]]
+ tree:
+ Sender
+ distribution: single
+ targetFragmentId: 2
+ est: (rows=71577)
+ Sort
+ collation: [ID ASC]
+ est: (rows=71577)
+ ColocatedMinus
+ all: true
+ est: (rows=71577)
+ TableScan
+ table: PUBLIC.T1_N1N2N3
+ fieldNames: [ID, C1]
+ est: (rows=100001)
+ TableScan
+ table: PUBLIC.T1_N1N2N3
+ predicate: SEARCH(ID, Sarg[1, 3])
+ fieldNames: [ID, C1]
+ est: (rows=56847)
+---
+
+N0
+SELECT id, c1 FROM (SELECT id, c1 FROM t1_n1n2n3 WHERE id IN (1, 1, 3, 3)
EXCEPT ALL SELECT id, c1 FROM t1_n1n2n3 WHERE id IN (1, 1, 3, 3)) tmp ORDER BY
id ASC
+---
+Fragment#2 root
+ distribution: single
+ executionNodes: [N0]
+ exchangeSourceNodes: {3=[N2]}
+ colocationGroup[-1]: {nodes=[N0], sourceIds=[-1, 3], assignments={},
partitionsWithConsistencyTokens={N0=[]}}
+ colocationGroup[3]: {nodes=[N0], sourceIds=[-1, 3], assignments={},
partitionsWithConsistencyTokens={N0=[]}}
+ tree:
+ Receiver
+ fieldNames: [ID, C1]
+ sourceFragmentId: 3
+ est: (rows=1)
+
+Fragment#3
+ distribution: table PUBLIC.T1_N1N2N3 in zone ZONE_1
+ executionNodes: [N2]
+ targetNodes: [N0]
+ colocationGroup[0]: {nodes=[N2], sourceIds=[0], assignments={part_1=N2:3},
partitionsWithConsistencyTokens={N2=[part_1:3]}}
+ colocationGroup[1]: {nodes=[N2], sourceIds=[1], assignments={part_1=N2:3},
partitionsWithConsistencyTokens={N2=[part_1:3]}}
+ partitions: [T1_N1N2N3=[N2={1}]]
+ tree:
+ Sender
+ distribution: single
+ targetFragmentId: 2
+ est: (rows=28424)
+ Sort
+ collation: [ID ASC]
+ est: (rows=28424)
+ ColocatedMinus
+ all: true
+ est: (rows=28424)
+ TableScan
+ table: PUBLIC.T1_N1N2N3
+ predicate: SEARCH(ID, Sarg[1, 3])
+ fieldNames: [ID, C1]
+ est: (rows=56847)
+ TableScan
+ table: PUBLIC.T1_N1N2N3
+ predicate: SEARCH(ID, Sarg[1, 3])
+ fieldNames: [ID, C1]
+ est: (rows=56847)
+---
Review Comment:
Thanks fixed.
##########
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/FragmentPrinter.java:
##########
@@ -50,7 +52,7 @@ public final class FragmentPrinter {
static String FRAGMENT_PREFIX = "Fragment#";
- private final boolean verbose;
Review Comment:
Thanks fixed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
