| N0 |
| INSERT INTO t1_n1 VALUES (1, 1, 1), (2, 2, 2) |
| --- |
| Fragment#3 root |
| distribution: single |
| executionNodes: [N0] |
| exchangeSourceNodes: {4=[N1]} |
| colocationGroup[-1]: {nodes=[N0], sourceIds=[-1, 4], assignments={}, partitionsWithConsistencyTokens={N0=[]}} |
| colocationGroup[4]: {nodes=[N0], sourceIds=[-1, 4], assignments={}, partitionsWithConsistencyTokens={N0=[]}} |
| tree: |
| Project |
| fieldNames: [ROWCOUNT] |
| projection: [CAST($f0):BIGINT NOT NULL] |
| est: (rows=1) |
| ColocatedHashAggregate |
| fieldNames: [$f0] |
| group: [] |
| aggregation: [$SUM0(ROWCOUNT)] |
| est: (rows=1) |
| Receiver |
| fieldNames: [ROWCOUNT] |
| sourceFragmentId: 4 |
| est: (rows=1) |
| |
| Fragment#4 |
| distribution: table PUBLIC.T1_N1 in zone ZONE_1 |
| executionNodes: [N1] |
| targetNodes: [N0] |
| colocationGroup[-1]: {nodes=[N1], sourceIds=[-1, 1], assignments={part_0=N1:1}, partitionsWithConsistencyTokens={N1=[part_0:1]}} |
| colocationGroup[0]: {nodes=[N1], sourceIds=[0], assignments={part_0=N1:1}, partitionsWithConsistencyTokens={N1=[part_0:1]}} |
| colocationGroup[1]: {nodes=[N1], sourceIds=[-1, 1], assignments={part_0=N1:1}, partitionsWithConsistencyTokens={N1=[part_0:1]}} |
| partitions: [T1_N1=[N1={0}]] |
| tree: |
| Sender |
| distribution: single |
| targetFragmentId: 3 |
| est: (rows=2) |
| TableModify |
| table: PUBLIC.T1_N1 |
| fieldNames: [ROWCOUNT] |
| type: INSERT |
| est: (rows=2) |
| TrimExchange |
| distribution: table PUBLIC.T1_N1 in zone ZONE_1 by [ID] |
| est: (rows=2) |
| Values |
| fieldNames: [ID, C1, C2] |
| tuples: [[1, 1, 1], [2, 2, 2]] |
| est: (rows=2) |
| --- |
| |
| N1 |
| UPDATE t1_n1 SET c2 = 1000 |
| --- |
| Fragment#2 root |
| distribution: single |
| executionNodes: [N1] |
| exchangeSourceNodes: {3=[N1]} |
| colocationGroup[-1]: {nodes=[N1], sourceIds=[-1, 3], assignments={}, partitionsWithConsistencyTokens={N1=[]}} |
| colocationGroup[3]: {nodes=[N1], sourceIds=[-1, 3], assignments={}, partitionsWithConsistencyTokens={N1=[]}} |
| tree: |
| Project |
| fieldNames: [ROWCOUNT] |
| projection: [CAST($f0):BIGINT NOT NULL] |
| est: (rows=1) |
| ColocatedHashAggregate |
| fieldNames: [$f0] |
| group: [] |
| aggregation: [$SUM0(ROWCOUNT)] |
| est: (rows=1) |
| Receiver |
| fieldNames: [ROWCOUNT] |
| sourceFragmentId: 3 |
| est: (rows=1) |
| |
| Fragment#3 |
| distribution: table PUBLIC.T1_N1 in zone ZONE_1 |
| executionNodes: [N1] |
| targetNodes: [N1] |
| colocationGroup[0]: {nodes=[N1], sourceIds=[0, 1], assignments={part_0=N1:1}, partitionsWithConsistencyTokens={N1=[part_0:1]}} |
| colocationGroup[1]: {nodes=[N1], sourceIds=[0, 1], assignments={part_0=N1:1}, partitionsWithConsistencyTokens={N1=[part_0:1]}} |
| partitions: [T1_N1=[N1={0}]] |
| tree: |
| Sender |
| distribution: single |
| targetFragmentId: 2 |
| est: (rows=100001) |
| TableModify |
| table: PUBLIC.T1_N1 |
| fieldNames: [ROWCOUNT] |
| type: UPDATE |
| est: (rows=100001) |
| TableScan |
| table: PUBLIC.T1_N1 |
| fieldNames: [ID, C1, C2, EXPR$0] |
| projection: [ID, C1, C2, 1000] |
| est: (rows=100001) |
| --- |
| |
| N2 |
| UPDATE t1_n1 SET c2 = 1000 |
| --- |
| Fragment#2 root |
| distribution: single |
| executionNodes: [N2] |
| exchangeSourceNodes: {3=[N1]} |
| colocationGroup[-1]: {nodes=[N2], sourceIds=[-1, 3], assignments={}, partitionsWithConsistencyTokens={N2=[]}} |
| colocationGroup[3]: {nodes=[N2], sourceIds=[-1, 3], assignments={}, partitionsWithConsistencyTokens={N2=[]}} |
| tree: |
| Project |
| fieldNames: [ROWCOUNT] |
| projection: [CAST($f0):BIGINT NOT NULL] |
| est: (rows=1) |
| ColocatedHashAggregate |
| fieldNames: [$f0] |
| group: [] |
| aggregation: [$SUM0(ROWCOUNT)] |
| est: (rows=1) |
| Receiver |
| fieldNames: [ROWCOUNT] |
| sourceFragmentId: 3 |
| est: (rows=1) |
| |
| Fragment#3 |
| distribution: table PUBLIC.T1_N1 in zone ZONE_1 |
| executionNodes: [N1] |
| targetNodes: [N2] |
| colocationGroup[0]: {nodes=[N1], sourceIds=[0, 1], assignments={part_0=N1:1}, partitionsWithConsistencyTokens={N1=[part_0:1]}} |
| colocationGroup[1]: {nodes=[N1], sourceIds=[0, 1], assignments={part_0=N1:1}, partitionsWithConsistencyTokens={N1=[part_0:1]}} |
| partitions: [T1_N1=[N1={0}]] |
| tree: |
| Sender |
| distribution: single |
| targetFragmentId: 2 |
| est: (rows=100001) |
| TableModify |
| table: PUBLIC.T1_N1 |
| fieldNames: [ROWCOUNT] |
| type: UPDATE |
| est: (rows=100001) |
| TableScan |
| table: PUBLIC.T1_N1 |
| fieldNames: [ID, C1, C2, EXPR$0] |
| projection: [ID, C1, C2, 1000] |
| est: (rows=100001) |
| --- |
| |
| N1 |
| UPDATE t2_n2n3 SET c2 = 1000 |
| --- |
| Fragment#2 root |
| distribution: single |
| executionNodes: [N1] |
| exchangeSourceNodes: {3=[N2, N3]} |
| colocationGroup[-1]: {nodes=[N1], sourceIds=[-1, 3], assignments={}, partitionsWithConsistencyTokens={N1=[]}} |
| colocationGroup[3]: {nodes=[N1], sourceIds=[-1, 3], assignments={}, partitionsWithConsistencyTokens={N1=[]}} |
| tree: |
| Project |
| fieldNames: [ROWCOUNT] |
| projection: [CAST($f0):BIGINT NOT NULL] |
| est: (rows=1) |
| ColocatedHashAggregate |
| fieldNames: [$f0] |
| group: [] |
| aggregation: [$SUM0(ROWCOUNT)] |
| est: (rows=1) |
| Receiver |
| fieldNames: [ROWCOUNT] |
| sourceFragmentId: 3 |
| est: (rows=1) |
| |
| Fragment#3 |
| distribution: table PUBLIC.T2_N2N3 in zone ZONE_2 |
| executionNodes: [N2, N3] |
| targetNodes: [N1] |
| colocationGroup[0]: {nodes=[N2, N3], sourceIds=[0, 1], assignments={part_0=N2:2, part_1=N3:2}, partitionsWithConsistencyTokens={N2=[part_0:2], N3=[part_1:2]}} |
| colocationGroup[1]: {nodes=[N2, N3], sourceIds=[0, 1], assignments={part_0=N2:2, part_1=N3:2}, partitionsWithConsistencyTokens={N2=[part_0:2], N3=[part_1:2]}} |
| partitions: [T2_N2N3=[N2={0}, N3={1}]] |
| tree: |
| Sender |
| distribution: single |
| targetFragmentId: 2 |
| est: (rows=100002) |
| TableModify |
| table: PUBLIC.T2_N2N3 |
| fieldNames: [ROWCOUNT] |
| type: UPDATE |
| est: (rows=100002) |
| TableScan |
| table: PUBLIC.T2_N2N3 |
| fieldNames: [ID, C1, C2, EXPR$0] |
| projection: [ID, C1, C2, 1000] |
| est: (rows=100002) |
| --- |
