-- DISTRIBUTE_RESULT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- UNNEST |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- PRE_CLUSTERED_GROUP_BY[$$227] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- AGGREGATE |LOCAL| | |
-- STREAM_SELECT |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$227][$$175] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- PRE_CLUSTERED_GROUP_BY[$$189] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- AGGREGATE |LOCAL| | |
-- STREAM_SELECT |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STABLE_SORT [$$189(ASC)] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$189][$$225] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- PRE_CLUSTERED_GROUP_BY[$$137] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- AGGREGATE |LOCAL| | |
-- STREAM_SELECT |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$137][$$187] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- BTREE_SEARCH (tpcds.item.item) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- SORT_GROUP_BY[$$234] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- HASH_PARTITION_EXCHANGE [$$234] |PARTITIONED| | |
-- PRE_CLUSTERED_GROUP_BY[$$186] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- STREAM_SELECT |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STABLE_SORT [$$186(ASC)] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$170][$$169] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$204] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- STREAM_SELECT |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- PRE_CLUSTERED_GROUP_BY[$$208] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- AGGREGATE |LOCAL| | |
-- STREAM_SELECT |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$208][$$209] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- BTREE_SEARCH (tpcds.item.item) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$207] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN (tpcds.store_sales) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$169] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN (tpcds.store_sales) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- SORT_GROUP_BY[$$240] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- HASH_PARTITION_EXCHANGE [$$240] |PARTITIONED| | |
-- PRE_CLUSTERED_GROUP_BY[$$224] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- STREAM_SELECT |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STABLE_SORT [$$224(ASC)] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$174][$$173] |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$174] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- STREAM_SELECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- PRE_CLUSTERED_GROUP_BY[$$194] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- AGGREGATE |LOCAL| | |
-- STREAM_SELECT |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STABLE_SORT [$$194(ASC)] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$194][$$171] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- PRE_CLUSTERED_GROUP_BY[$$195] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- AGGREGATE |LOCAL| | |
-- STREAM_SELECT |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$195][$$197] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- BTREE_SEARCH (tpcds.item.item) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- SORT_GROUP_BY[$$237] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- HASH_PARTITION_EXCHANGE [$$237] |PARTITIONED| | |
-- PRE_CLUSTERED_GROUP_BY[$$203] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- STREAM_SELECT |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STABLE_SORT [$$203(ASC)] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$204][$$207] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$204] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- STREAM_SELECT |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- PRE_CLUSTERED_GROUP_BY[$$208] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- AGGREGATE |LOCAL| | |
-- STREAM_SELECT |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$208][$$209] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- BTREE_SEARCH (tpcds.item.item) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$207] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN (tpcds.store_sales) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$207] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN (tpcds.store_sales) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$207] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN (tpcds.store_sales) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$173] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN (tpcds.store_sales) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$207] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- REPLICATE |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN (tpcds.store_sales) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| |