Skip to content

Instantly share code, notes, and snippets.

@nileema
Created October 2, 2015 19:46
Show Gist options
  • Star 1 You must be signed in to star a gist
  • Fork 1 You must be signed in to fork a gist
  • Save nileema/b3ddbe380a794ee509c1 to your computer and use it in GitHub Desktop.
Save nileema/b3ddbe380a794ee509c1 to your computer and use it in GitHub Desktop.
select *
FROM
(select orderkey, count(*) from orders group by orderkey) a
JOIN
(select orderkey, count(*) from lineitem group by orderkey) b
on a.orderkey = b.orderkey
Query Plan
---------------------------------------------------------------------------------------------------------------------------------------------
Fragment 0 [SINGLE]
Output layout: [orderkey, count, orderkey_8, count_12]
- Output[orderkey, _col1, orderkey, _col3] => [orderkey:bigint, count:bigint, orderkey_8:bigint, count_12:bigint]
_col1 := count
orderkey := orderkey_8
_col3 := count_12
- RemoteSource[1] => [orderkey:bigint, count:bigint, count_12:bigint, orderkey_8:bigint]
Fragment 1 [FIXED]
Output layout: [orderkey, count, count_12, orderkey_8]
- InnerJoin[("$hashvalue_42" = "$hashvalue_43") AND ("orderkey" = "orderkey_8") AND ("$hashvalue_42" = "$hashvalue_43")] => [$hashvalue_
- RemoteSource[2] => [$hashvalue_42:bigint, orderkey:bigint, count:bigint]
- RemoteSource[3] => [$hashvalue_43:bigint, orderkey_8:bigint, count_12:bigint]
Fragment 2 [SOURCE]
Output layout: [$hashvalue_42, orderkey, count]
Output partitioning: [orderkey]
- Project => [$hashvalue_42:bigint, orderkey:bigint, count:bigint]
$hashvalue_42 := "combine_hash"(0, COALESCE("$operator$hash_code"("orderkey"), 0))
- Aggregate[orderkey] => [orderkey:bigint, $hashvalue:bigint, count:bigint]
count := "count"(*)
- Project => [orderkey:bigint, $hashvalue:bigint]
$hashvalue := "combine_hash"(0, COALESCE("$operator$hash_code"("orderkey"), 0))
- TableScan[tpch:tpch:orders:sf0.01, originalConstraint = true] => [orderkey:bigint]
orderkey := tpch:orderkey
Fragment 3 [SOURCE]
Output layout: [$hashvalue_43, orderkey_8, count_12]
Output partitioning: [orderkey_8]
- Project => [$hashvalue_43:bigint, orderkey_8:bigint, count_12:bigint]
$hashvalue_43 := "combine_hash"(0, COALESCE("$operator$hash_code"("orderkey_8"), 0))
- Aggregate[orderkey_8] => [orderkey_8:bigint, $hashvalue_41:bigint, count_12:bigint]
count_12 := "count"(*)
- Project => [orderkey_8:bigint, $hashvalue_41:bigint]
$hashvalue_41 := "combine_hash"(0, COALESCE("$operator$hash_code"("orderkey_8"), 0))
- TableScan[tpch:tpch:lineitem:sf0.01, originalConstraint = true] => [orderkey_8:bigint]
orderkey_8 := tpch:orderkey
(1 row)
Query 20151002_182944_00002_skzci, FINISHED, 1 node
http://localhost:8080/v1/query/20151002_182944_00002_skzci?pretty
Splits: 1 total, 1 done (100.00%)
CPU Time: 0.0s total, 0 rows/s, 0B/s, 0% active
Per Node: 0.0 parallelism, 0 rows/s, 0B/s
Parallelism: 0.0
0:30 [0 rows, 0B] [0 rows/s, 0B/s]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment