modules/sql-engine/src/test/resources/mapping/union.test

N1
SELECT /*+ DISABLE_RULE('ColocatedHashAggregateConverterRule')*/ * FROM
  (SELECT * FROM t1_n1 UNION SELECT * FROM t2_n1)
---
Fragment#0 root
  distribution: single
  executionNodes: [N1]
  exchangeSourceNodes: {1=[N1]}
  tree: 
    ReduceHashAggregate
        fieldNames: [ID, C1, C2]
        group: [ID, C1, C2]
        aggregation: []
        est: (rows=1)
      Receiver
          fieldNames: [ID, C1, C2, _GROUP_ID]
          sourceFragmentId: 1
          est: (rows=1)

Fragment#1
  distribution: random
  executionNodes: [N1]
  targetNodes: [N1]
  partitions: [T2_N1=[N1={0}], T1_N1=[N1={0}]]
  tree: 
    Sender
        distribution: single
        targetFragmentId: 0
        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#0 root
  distribution: single
  executionNodes: [N1]
  exchangeSourceNodes: {1=[N1]}
  tree: 
    Receiver
        fieldNames: [ID, C1, C2]
        sourceFragmentId: 1
        est: (rows=1)

Fragment#1
  distribution: table PUBLIC.T2_N1 in zone ZONE_3
  executionNodes: [N1]
  targetNodes: [N1]
  exchangeSourceNodes: {2=[N1]}
  partitions: [T2_N1=[N1={0}]]
  tree: 
    Sender
        distribution: single
        targetFragmentId: 0
        est: (rows=48802)
      ColocatedHashAggregate
          group: [ID, C1, C2]
          aggregation: []
          est: (rows=48802)
        UnionAll
            est: (rows=100004)
          Receiver
              fieldNames: [ID, C1, C2]
              sourceFragmentId: 2
              est: (rows=1)
          TableScan
              table: PUBLIC.T2_N1
              fieldNames: [ID, C1, C2]
              est: (rows=100003)

Fragment#2
  distribution: table PUBLIC.T1_N1 in zone ZONE_1
  executionNodes: [N1]
  targetNodes: [N1]
  partitions: [T1_N1=[N1={0}]]
  tree: 
    Sender
        distribution: table PUBLIC.T2_N1 in zone ZONE_3 by [ID]
        targetFragmentId: 1
        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#0 root
  distribution: single
  executionNodes: [N1]
  exchangeSourceNodes: {1=[N1, N2]}
  tree: 
    ReduceHashAggregate
        fieldNames: [ID, C1, C2]
        group: [ID, C1, C2]
        aggregation: []
        est: (rows=1)
      Receiver
          fieldNames: [ID, C1, C2, _GROUP_ID]
          sourceFragmentId: 1
          est: (rows=1)

Fragment#1
  distribution: random
  executionNodes: [N1, N2]
  targetNodes: [N1]
  partitions: [T2_N1N2=[N1={0}, N2={1}], T1_N1N2=[N1={0}, N2={1}]]
  tree: 
    Sender
        distribution: single
        targetFragmentId: 0
        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#0 root
  distribution: single
  executionNodes: [N1]
  exchangeSourceNodes: {1=[N1, N2]}
  tree: 
    Receiver
        fieldNames: [ID, C1, C2]
        sourceFragmentId: 1
        est: (rows=1)

Fragment#1
  distribution: table PUBLIC.T2_N1N2 in zone ZONE_4
  executionNodes: [N1, N2]
  targetNodes: [N1]
  exchangeSourceNodes: {2=[N1, N2]}
  partitions: [T2_N1N2=[N1={0}, N2={1}]]
  tree: 
    Sender
        distribution: single
        targetFragmentId: 0
        est: (rows=48802)
      ColocatedHashAggregate
          group: [ID, C1, C2]
          aggregation: []
          est: (rows=48802)
        UnionAll
            est: (rows=100005)
          Receiver
              fieldNames: [ID, C1, C2]
              sourceFragmentId: 2
              est: (rows=1)
          TableScan
              table: PUBLIC.T2_N1N2
              fieldNames: [ID, C1, C2]
              est: (rows=100004)

Fragment#2
  distribution: table PUBLIC.T1_N1N2 in zone ZONE_2
  executionNodes: [N1, N2]
  targetNodes: [N1, N2]
  partitions: [T1_N1N2=[N1={0}, N2={1}]]
  tree: 
    Sender
        distribution: table PUBLIC.T2_N1N2 in zone ZONE_4 by [ID]
        targetFragmentId: 1
        est: (rows=100002)
      TableScan
          table: PUBLIC.T1_N1N2
          fieldNames: [ID, C1, C2]
          est: (rows=100002)
---