| N0 |
| INSERT INTO t1_n1 VALUES (1, 1, 1), (2, 2, 2) |
| --- |
| Fragment#0 root |
| executionNodes: [N0] |
| remoteFragments: [1] |
| exchangeSourceNodes: {1=[N1]} |
| tree: |
| Project |
| ColocatedHashAggregate |
| Receiver(sourceFragment=1, exchange=1, distribution=single) |
| |
| Fragment#1 |
| targetNodes: [N0] |
| executionNodes: [N1] |
| tables: [T1_N1] |
| partitions: {N1=[0:1]} |
| tree: |
| Sender(targetFragment=0, exchange=1, distribution=single) |
| TableModify(name=PUBLIC.T1_N1, source=2, distribution=affinity[table: T1_N1, columns: [ID]]) |
| TrimExchange |
| Values |
| --- |
| |
| N1 |
| UPDATE t1_n1 SET c2 = 1000 |
| --- |
| Fragment#0 root |
| executionNodes: [N1] |
| remoteFragments: [1] |
| exchangeSourceNodes: {1=[N1]} |
| tree: |
| Project |
| ColocatedHashAggregate |
| Receiver(sourceFragment=1, exchange=1, distribution=single) |
| |
| Fragment#1 |
| targetNodes: [N1] |
| executionNodes: [N1] |
| tables: [T1_N1, T1_N1] |
| partitions: {N1=[0:1]} |
| tree: |
| Sender(targetFragment=0, exchange=1, distribution=single) |
| TableModify(name=PUBLIC.T1_N1, source=2, distribution=affinity[table: T1_N1, columns: [ID]]) |
| TableScan(name=PUBLIC.T1_N1, source=3, partitions=1, distribution=affinity[table: T1_N1, columns: [ID]]) |
| --- |
| |
| N2 |
| UPDATE t1_n1 SET c2 = 1000 |
| --- |
| Fragment#0 root |
| executionNodes: [N2] |
| remoteFragments: [1] |
| exchangeSourceNodes: {1=[N1]} |
| tree: |
| Project |
| ColocatedHashAggregate |
| Receiver(sourceFragment=1, exchange=1, distribution=single) |
| |
| Fragment#1 |
| targetNodes: [N2] |
| executionNodes: [N1] |
| tables: [T1_N1, T1_N1] |
| partitions: {N1=[0:1]} |
| tree: |
| Sender(targetFragment=0, exchange=1, distribution=single) |
| TableModify(name=PUBLIC.T1_N1, source=2, distribution=affinity[table: T1_N1, columns: [ID]]) |
| TableScan(name=PUBLIC.T1_N1, source=3, partitions=1, distribution=affinity[table: T1_N1, columns: [ID]]) |
| --- |
| |
| N1 |
| UPDATE t2_n2n3 SET c2 = 1000 |
| --- |
| Fragment#0 root |
| executionNodes: [N1] |
| remoteFragments: [1] |
| exchangeSourceNodes: {1=[N2, N3]} |
| tree: |
| Project |
| ColocatedHashAggregate |
| Receiver(sourceFragment=1, exchange=1, distribution=single) |
| |
| Fragment#1 |
| targetNodes: [N1] |
| executionNodes: [N2, N3] |
| tables: [T2_N2N3, T2_N2N3] |
| partitions: {N2=[0:2], N3=[1:2]} |
| tree: |
| Sender(targetFragment=0, exchange=1, distribution=single) |
| TableModify(name=PUBLIC.T2_N2N3, source=2, distribution=affinity[table: T2_N2N3, columns: [ID]]) |
| TableScan(name=PUBLIC.T2_N2N3, source=3, partitions=2, distribution=affinity[table: T2_N2N3, columns: [ID]]) |
| --- |
