blob: b0f993c11d9c743635337fafff0cf9c436a6436f [file]
N1
SELECT * FROM t1_n1
---
Fragment#0 root
executionNodes: [N1]
remoteFragments: [1]
exchangeSourceNodes: {1=[N1]}
tree:
Receiver(sourceFragment=1, exchange=1, distribution=single)
Fragment#1
targetNodes: [N1]
executionNodes: [N1]
tables: [T1_N1]
partitions: {N1=[0:1]}
tree:
Sender(targetFragment=0, exchange=1, distribution=single)
TableScan(name=PUBLIC.T1_N1, source=2, partitions=1, distribution=affinity[table: T1_N1, columns: [ID]])
---
N2
SELECT * FROM t1_n1
---
Fragment#0 root
executionNodes: [N2]
remoteFragments: [1]
exchangeSourceNodes: {1=[N1]}
tree:
Receiver(sourceFragment=1, exchange=1, distribution=single)
Fragment#1
targetNodes: [N2]
executionNodes: [N1]
tables: [T1_N1]
partitions: {N1=[0:1]}
tree:
Sender(targetFragment=0, exchange=1, distribution=single)
TableScan(name=PUBLIC.T1_N1, source=2, partitions=1, distribution=affinity[table: T1_N1, columns: [ID]])
---
N1
SELECT * FROM t1_n1 WHERE ID = 0
---
Fragment#0 root
executionNodes: [N1]
remoteFragments: [1]
exchangeSourceNodes: {1=[N1]}
tree:
Receiver(sourceFragment=1, exchange=1, distribution=single)
Fragment#1
targetNodes: [N1]
executionNodes: [N1]
tables: [T1_N1]
partitions: {N1=[0:1]}
tree:
Sender(targetFragment=0, exchange=1, distribution=single)
TableScan(name=PUBLIC.T1_N1, source=2, partitions=1, distribution=affinity[table: T1_N1, columns: [ID]])
---
N1
SELECT * FROM t2_n1n2
---
Fragment#0 root
executionNodes: [N1]
remoteFragments: [1]
exchangeSourceNodes: {1=[N1, N2]}
tree:
Receiver(sourceFragment=1, exchange=1, distribution=single)
Fragment#1
targetNodes: [N1]
executionNodes: [N1, N2]
tables: [T2_N1N2]
partitions: {N1=[0:2], N2=[1:2]}
tree:
Sender(targetFragment=0, exchange=1, distribution=single)
TableScan(name=PUBLIC.T2_N1N2, source=2, partitions=2, distribution=affinity[table: T2_N1N2, columns: [ID]])
---