| N1 |
| SELECT /*+ DISABLE_RULE('ColocatedHashAggregateConverterRule')*/ * FROM |
| (SELECT * FROM t1_n1 UNION SELECT * FROM t2_n1) |
| --- |
| 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: |
| ReduceHashAggregate |
| fieldNames: [ID, C1, C2] |
| group: [ID, C1, C2] |
| aggregation: [] |
| est: (rows=1) |
| Receiver |
| fieldNames: [ID, C1, C2, _GROUP_ID] |
| sourceFragmentId: 3 |
| est: (rows=1) |
| |
| Fragment#3 |
| distribution: random |
| executionNodes: [N1] |
| targetNodes: [N1] |
| colocationGroup[0]: {nodes=[N1], sourceIds=[0], assignments={part_0=N1:1}, partitionsWithConsistencyTokens={N1=[part_0:1]}} |
| colocationGroup[1]: {nodes=[N1], sourceIds=[1], assignments={part_0=N1:1}, partitionsWithConsistencyTokens={N1=[part_0:1]}} |
| partitions: [T2_N1=[N1={0}], T1_N1=[N1={0}]] |
| tree: |
| Sender |
| distribution: single |
| targetFragmentId: 2 |
| est: (rows=97602) |
| MapHashAggregate |
| fieldNames: [ID, C1, C2, _GROUP_ID] |
| group: [ID, C1, C2] |
| aggregation: [] |
| est: (rows=97602) |
| UnionAll |
| est: (rows=200004) |
| TableScan |
| table: PUBLIC.T1_N1 |
| fieldNames: [ID, C1, C2] |
| est: (rows=100001) |
| TableScan |
| table: PUBLIC.T2_N1 |
| fieldNames: [ID, C1, C2] |
| est: (rows=100003) |
| --- |
| |
| N1 |
| SELECT /*+ DISABLE_RULE('MapReduceHashAggregateConverterRule')*/ * FROM |
| (SELECT * FROM t1_n1 UNION SELECT * FROM t2_n1) |
| --- |
| 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: |
| Receiver |
| fieldNames: [ID, C1, C2] |
| sourceFragmentId: 3 |
| est: (rows=1) |
| |
| Fragment#3 |
| distribution: table PUBLIC.T2_N1 in zone ZONE_3 |
| executionNodes: [N1] |
| targetNodes: [N1] |
| exchangeSourceNodes: {4=[N1]} |
| colocationGroup[1]: {nodes=[N1], sourceIds=[1, 4], assignments={part_0=N1:1}, partitionsWithConsistencyTokens={N1=[part_0:1]}} |
| colocationGroup[4]: {nodes=[N1], sourceIds=[1, 4], assignments={part_0=N1:1}, partitionsWithConsistencyTokens={N1=[part_0:1]}} |
| partitions: [T2_N1=[N1={0}]] |
| tree: |
| Sender |
| distribution: single |
| targetFragmentId: 2 |
| est: (rows=48802) |
| ColocatedHashAggregate |
| group: [ID, C1, C2] |
| aggregation: [] |
| est: (rows=48802) |
| UnionAll |
| est: (rows=100004) |
| Receiver |
| fieldNames: [ID, C1, C2] |
| sourceFragmentId: 4 |
| est: (rows=1) |
| TableScan |
| table: PUBLIC.T2_N1 |
| fieldNames: [ID, C1, C2] |
| est: (rows=100003) |
| |
| Fragment#4 |
| distribution: table PUBLIC.T1_N1 in zone ZONE_1 |
| executionNodes: [N1] |
| targetNodes: [N1] |
| colocationGroup[0]: {nodes=[N1], sourceIds=[0], assignments={part_0=N1:1}, partitionsWithConsistencyTokens={N1=[part_0:1]}} |
| partitions: [T1_N1=[N1={0}]] |
| tree: |
| Sender |
| distribution: table PUBLIC.T2_N1 in zone ZONE_3 by [ID] |
| targetFragmentId: 3 |
| est: (rows=100001) |
| TableScan |
| table: PUBLIC.T1_N1 |
| fieldNames: [ID, C1, C2] |
| est: (rows=100001) |
| --- |
| |
| N1 |
| SELECT /*+ DISABLE_RULE('ColocatedHashAggregateConverterRule')*/ * FROM |
| (SELECT * FROM t1_n1n2 UNION SELECT * FROM t2_n1n2) |
| --- |
| Fragment#2 root |
| distribution: single |
| executionNodes: [N1] |
| exchangeSourceNodes: {3=[N1, N2]} |
| colocationGroup[-1]: {nodes=[N1], sourceIds=[-1, 3], assignments={}, partitionsWithConsistencyTokens={N1=[]}} |
| colocationGroup[3]: {nodes=[N1], sourceIds=[-1, 3], assignments={}, partitionsWithConsistencyTokens={N1=[]}} |
| tree: |
| ReduceHashAggregate |
| fieldNames: [ID, C1, C2] |
| group: [ID, C1, C2] |
| aggregation: [] |
| est: (rows=1) |
| Receiver |
| fieldNames: [ID, C1, C2, _GROUP_ID] |
| sourceFragmentId: 3 |
| est: (rows=1) |
| |
| Fragment#3 |
| distribution: random |
| executionNodes: [N1, N2] |
| targetNodes: [N1] |
| colocationGroup[0]: {nodes=[N1, N2], sourceIds=[0], assignments={part_0=N1:2, part_1=N2:2}, partitionsWithConsistencyTokens={N1=[part_0:2], N2=[part_1:2]}} |
| colocationGroup[1]: {nodes=[N1, N2], sourceIds=[1], assignments={part_0=N1:2, part_1=N2:2}, partitionsWithConsistencyTokens={N1=[part_0:2], N2=[part_1:2]}} |
| partitions: [T2_N1N2=[N1={0}, N2={1}], T1_N1N2=[N1={0}, N2={1}]] |
| tree: |
| Sender |
| distribution: single |
| targetFragmentId: 2 |
| est: (rows=97603) |
| MapHashAggregate |
| fieldNames: [ID, C1, C2, _GROUP_ID] |
| group: [ID, C1, C2] |
| aggregation: [] |
| est: (rows=97603) |
| UnionAll |
| est: (rows=200006) |
| TableScan |
| table: PUBLIC.T1_N1N2 |
| fieldNames: [ID, C1, C2] |
| est: (rows=100002) |
| TableScan |
| table: PUBLIC.T2_N1N2 |
| fieldNames: [ID, C1, C2] |
| est: (rows=100004) |
| --- |
| |
| N1 |
| SELECT /*+ DISABLE_RULE('MapReduceHashAggregateConverterRule')*/ * FROM |
| (SELECT * FROM t1_n1n2 UNION SELECT * FROM t2_n1n2) |
| --- |
| Fragment#2 root |
| distribution: single |
| executionNodes: [N1] |
| exchangeSourceNodes: {3=[N1, N2]} |
| colocationGroup[-1]: {nodes=[N1], sourceIds=[-1, 3], assignments={}, partitionsWithConsistencyTokens={N1=[]}} |
| colocationGroup[3]: {nodes=[N1], sourceIds=[-1, 3], assignments={}, partitionsWithConsistencyTokens={N1=[]}} |
| tree: |
| Receiver |
| fieldNames: [ID, C1, C2] |
| sourceFragmentId: 3 |
| est: (rows=1) |
| |
| Fragment#3 |
| distribution: table PUBLIC.T2_N1N2 in zone ZONE_4 |
| executionNodes: [N1, N2] |
| targetNodes: [N1] |
| exchangeSourceNodes: {4=[N1, N2]} |
| colocationGroup[1]: {nodes=[N1, N2], sourceIds=[1, 4], assignments={part_0=N1:2, part_1=N2:2}, partitionsWithConsistencyTokens={N1=[part_0:2], N2=[part_1:2]}} |
| colocationGroup[4]: {nodes=[N1, N2], sourceIds=[1, 4], assignments={part_0=N1:2, part_1=N2:2}, partitionsWithConsistencyTokens={N1=[part_0:2], N2=[part_1:2]}} |
| partitions: [T2_N1N2=[N1={0}, N2={1}]] |
| tree: |
| Sender |
| distribution: single |
| targetFragmentId: 2 |
| est: (rows=48802) |
| ColocatedHashAggregate |
| group: [ID, C1, C2] |
| aggregation: [] |
| est: (rows=48802) |
| UnionAll |
| est: (rows=100005) |
| Receiver |
| fieldNames: [ID, C1, C2] |
| sourceFragmentId: 4 |
| est: (rows=1) |
| TableScan |
| table: PUBLIC.T2_N1N2 |
| fieldNames: [ID, C1, C2] |
| est: (rows=100004) |
| |
| Fragment#4 |
| distribution: table PUBLIC.T1_N1N2 in zone ZONE_2 |
| executionNodes: [N1, N2] |
| targetNodes: [N1, N2] |
| colocationGroup[0]: {nodes=[N1, N2], sourceIds=[0], assignments={part_0=N1:2, part_1=N2:2}, partitionsWithConsistencyTokens={N1=[part_0:2], N2=[part_1:2]}} |
| partitions: [T1_N1N2=[N1={0}, N2={1}]] |
| tree: |
| Sender |
| distribution: table PUBLIC.T2_N1N2 in zone ZONE_4 by [ID] |
| targetFragmentId: 3 |
| est: (rows=100002) |
| TableScan |
| table: PUBLIC.T1_N1N2 |
| fieldNames: [ID, C1, C2] |
| est: (rows=100002) |
| --- |
