Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,10 @@ HiveProject(d_date_sk=[$0])
CBO PLAN:
HiveSortLimit(sort0=[$0], dir0=[ASC], fetch=[100])
HiveProject(c_customer_id=[$1])
HiveJoin(condition=[AND(=($3, $7), >($4, $6))], joinType=[inner], algorithm=[none], cost=[not available])
HiveJoin(condition=[=($2, $0)], joinType=[inner], algorithm=[none], cost=[not available])
HiveProject(c_customer_sk=[$0], c_customer_id=[$1])
HiveTableScan(table=[[default, customer]], table:alias=[customer])
HiveJoin(condition=[=($2, $0)], joinType=[inner], algorithm=[none], cost=[not available])
HiveProject(c_customer_sk=[$0], c_customer_id=[$1])
HiveTableScan(table=[[default, customer]], table:alias=[customer])
HiveJoin(condition=[AND(=($1, $5), >($2, $4))], joinType=[inner], algorithm=[none], cost=[not available])
HiveJoin(condition=[=($3, $1)], joinType=[inner], algorithm=[none], cost=[not available])
HiveProject(sr_customer_sk=[$0], sr_store_sk=[$1], $f2=[$2])
HiveFilter(condition=[IS NOT NULL($2)])
Expand All @@ -24,16 +24,16 @@ HiveSortLimit(sort0=[$0], dir0=[ASC], fetch=[100])
HiveProject(s_store_sk=[$0])
HiveFilter(condition=[=($24, _UTF-16LE'NM')])
HiveTableScan(table=[[default, store]], table:alias=[store])
HiveProject(_o__c0=[*(CAST(/($1, $2)):DECIMAL(21, 6), 1.2:DECIMAL(2, 1))], ctr_store_sk=[$0])
HiveFilter(condition=[IS NOT NULL(CAST(/($1, $2)):DECIMAL(21, 6))])
HiveAggregate(group=[{1}], agg#0=[sum($2)], agg#1=[count($2)])
HiveProject(sr_customer_sk=[$0], sr_store_sk=[$1], $f2=[$2])
HiveAggregate(group=[{0, 1}], agg#0=[sum($2)])
HiveJoin(condition=[=($3, $4)], joinType=[inner], algorithm=[none], cost=[not available])
HiveProject(sr_customer_sk=[$2], sr_store_sk=[$6], sr_fee=[$13], sr_returned_date_sk=[$19])
HiveFilter(condition=[AND(IS NOT NULL($6), IS NOT NULL($19))])
HiveTableScan(table=[[default, store_returns]], table:alias=[store_returns])
HiveProject(d_date_sk=[$0])
HiveFilter(condition=[=($6, 2000)])
HiveTableScan(table=[[default, date_dim]], table:alias=[date_dim])
HiveProject(_o__c0=[*(CAST(/($1, $2)):DECIMAL(21, 6), 1.2:DECIMAL(2, 1))], ctr_store_sk=[$0])
HiveFilter(condition=[IS NOT NULL(CAST(/($1, $2)):DECIMAL(21, 6))])
HiveAggregate(group=[{1}], agg#0=[sum($2)], agg#1=[count($2)])
HiveProject(sr_customer_sk=[$0], sr_store_sk=[$1], $f2=[$2])
HiveAggregate(group=[{0, 1}], agg#0=[sum($2)])
HiveJoin(condition=[=($3, $4)], joinType=[inner], algorithm=[none], cost=[not available])
HiveProject(sr_customer_sk=[$2], sr_store_sk=[$6], sr_fee=[$13], sr_returned_date_sk=[$19])
HiveFilter(condition=[AND(IS NOT NULL($6), IS NOT NULL($19))])
HiveTableScan(table=[[default, store_returns]], table:alias=[store_returns])
HiveProject(d_date_sk=[$0])
HiveFilter(condition=[=($6, 2000)])
HiveTableScan(table=[[default, date_dim]], table:alias=[date_dim])

Original file line number Diff line number Diff line change
@@ -1,23 +1,23 @@
CBO PLAN:
HiveSortLimit(sort0=[$0], dir0=[ASC], fetch=[100])
HiveProject(i_item_id=[$0], agg1=[/(CAST($1):DOUBLE, $2)], agg2=[CAST(/($3, $4)):DECIMAL(11, 6)], agg3=[CAST(/($5, $6)):DECIMAL(11, 6)], agg4=[CAST(/($7, $8)):DECIMAL(11, 6)])
HiveAggregate(group=[{12}], agg#0=[sum($3)], agg#1=[count($3)], agg#2=[sum($4)], agg#3=[count($4)], agg#4=[sum($6)], agg#5=[count($6)], agg#6=[sum($5)], agg#7=[count($5)])
HiveJoin(condition=[=($1, $11)], joinType=[inner], algorithm=[none], cost=[not available])
HiveJoin(condition=[=($2, $10)], joinType=[inner], algorithm=[none], cost=[not available])
HiveJoin(condition=[=($0, $9)], joinType=[inner], algorithm=[none], cost=[not available])
HiveJoin(condition=[=($7, $8)], joinType=[inner], algorithm=[none], cost=[not available])
HiveAggregate(group=[{1}], agg#0=[sum($5)], agg#1=[count($5)], agg#2=[sum($6)], agg#3=[count($6)], agg#4=[sum($8)], agg#5=[count($8)], agg#6=[sum($7)], agg#7=[count($7)])
HiveJoin(condition=[=($3, $0)], joinType=[inner], algorithm=[none], cost=[not available])
HiveProject(i_item_sk=[$0], i_item_id=[$1])
HiveTableScan(table=[[default, item]], table:alias=[item])
HiveJoin(condition=[=($0, $10)], joinType=[inner], algorithm=[none], cost=[not available])
HiveJoin(condition=[=($7, $9)], joinType=[inner], algorithm=[none], cost=[not available])
HiveJoin(condition=[=($2, $8)], joinType=[inner], algorithm=[none], cost=[not available])
HiveProject(cs_bill_cdemo_sk=[$3], cs_item_sk=[$14], cs_promo_sk=[$15], cs_quantity=[$17], cs_list_price=[$19], cs_sales_price=[$20], cs_coupon_amt=[$26], cs_sold_date_sk=[$33])
HiveFilter(condition=[AND(IS NOT NULL($15), IS NOT NULL($3), IS NOT NULL($33))])
HiveTableScan(table=[[default, catalog_sales]], table:alias=[catalog_sales])
HiveProject(d_date_sk=[$0])
HiveFilter(condition=[=($6, 1998)])
HiveTableScan(table=[[default, date_dim]], table:alias=[date_dim])
HiveProject(cd_demo_sk=[$0])
HiveFilter(condition=[AND(=($2, _UTF-16LE'W'), =($1, _UTF-16LE'F'), =($3, _UTF-16LE'Primary '))])
HiveTableScan(table=[[default, customer_demographics]], table:alias=[customer_demographics])
HiveProject(p_promo_sk=[$0])
HiveFilter(condition=[OR(=($9, _UTF-16LE'N'), =($14, _UTF-16LE'N'))])
HiveTableScan(table=[[default, promotion]], table:alias=[promotion])
HiveProject(i_item_sk=[$0], i_item_id=[$1])
HiveTableScan(table=[[default, item]], table:alias=[item])
HiveProject(p_promo_sk=[$0])
HiveFilter(condition=[OR(=($9, _UTF-16LE'N'), =($14, _UTF-16LE'N'))])
HiveTableScan(table=[[default, promotion]], table:alias=[promotion])
HiveProject(d_date_sk=[$0])
HiveFilter(condition=[=($6, 1998)])
HiveTableScan(table=[[default, date_dim]], table:alias=[date_dim])
HiveProject(cd_demo_sk=[$0])
HiveFilter(condition=[AND(=($2, _UTF-16LE'W'), =($1, _UTF-16LE'F'), =($3, _UTF-16LE'Primary '))])
HiveTableScan(table=[[default, customer_demographics]], table:alias=[customer_demographics])

Original file line number Diff line number Diff line change
Expand Up @@ -56,10 +56,10 @@ HiveProject(i_category=[$0], d_year=[$1], d_moy=[$2], avg_monthly_sales=[$3], su
HiveFilter(condition=[AND(IN($6, 1999, 2000, 2001), OR(=($6, 2000), IN(ROW($6, $8), ROW(1999, 12), ROW(2001, 1))))])
HiveTableScan(table=[[default, date_dim]], table:alias=[date_dim])
HiveProject(s_store_sk=[$0], s_store_name=[$5], s_company_name=[$17])
HiveFilter(condition=[AND(IS NOT NULL($5), IS NOT NULL($17))])
HiveFilter(condition=[AND(IS NOT NULL($17), IS NOT NULL($5))])
HiveTableScan(table=[[default, store]], table:alias=[store])
HiveProject(i_item_sk=[$0], i_brand=[$8], i_category=[$12])
HiveFilter(condition=[AND(IS NOT NULL($12), IS NOT NULL($8))])
HiveFilter(condition=[AND(IS NOT NULL($8), IS NOT NULL($12))])
HiveTableScan(table=[[default, item]], table:alias=[item])
HiveJoin(condition=[AND(=($6, $0), =($7, $1), =($8, $2), =($9, $3), =($14, $5))], joinType=[inner], algorithm=[none], cost=[not available])
HiveProject((tok_table_or_col i_category)=[$0], (tok_table_or_col i_brand)=[$1], (tok_table_or_col s_store_name)=[$2], (tok_table_or_col s_company_name)=[$3], (tok_function sum (tok_table_or_col ss_sales_price))=[$4], EXPR$0=[+($5, 1)])
Expand All @@ -77,10 +77,10 @@ HiveProject(i_category=[$0], d_year=[$1], d_moy=[$2], avg_monthly_sales=[$3], su
HiveFilter(condition=[AND(IN($6, 1999, 2000, 2001), OR(=($6, 2000), IN(ROW($6, $8), ROW(1999, 12), ROW(2001, 1))))])
HiveTableScan(table=[[default, date_dim]], table:alias=[date_dim])
HiveProject(s_store_sk=[$0], s_store_name=[$5], s_company_name=[$17])
HiveFilter(condition=[AND(IS NOT NULL($5), IS NOT NULL($17))])
HiveFilter(condition=[AND(IS NOT NULL($17), IS NOT NULL($5))])
HiveTableScan(table=[[default, store]], table:alias=[store])
HiveProject(i_item_sk=[$0], i_brand=[$8], i_category=[$12])
HiveFilter(condition=[AND(IS NOT NULL($12), IS NOT NULL($8))])
HiveFilter(condition=[AND(IS NOT NULL($8), IS NOT NULL($12))])
HiveTableScan(table=[[default, item]], table:alias=[item])
HiveProject((tok_table_or_col i_category)=[$0], (tok_table_or_col i_brand)=[$1], (tok_table_or_col s_store_name)=[$2], (tok_table_or_col s_company_name)=[$3], (tok_table_or_col d_year)=[$4], (tok_table_or_col d_moy)=[$5], (tok_function sum (tok_table_or_col ss_sales_price))=[$6], avg_window_0=[$7], rank_window_1=[$8])
HiveFilter(condition=[AND(=($4, 2000), >($7, 0:DECIMAL(1, 0)), CASE(>($7, 0:DECIMAL(1, 0)), >(/(ABS(-($6, $7)), $7), 0.1:DECIMAL(1, 1)), false), IS NOT NULL($8))])
Expand All @@ -97,9 +97,9 @@ HiveProject(i_category=[$0], d_year=[$1], d_moy=[$2], avg_monthly_sales=[$3], su
HiveFilter(condition=[AND(IN($6, 1999, 2000, 2001), OR(=($6, 2000), IN(ROW($6, $8), ROW(1999, 12), ROW(2001, 1))))])
HiveTableScan(table=[[default, date_dim]], table:alias=[date_dim])
HiveProject(s_store_sk=[$0], s_store_name=[$5], s_company_name=[$17])
HiveFilter(condition=[AND(IS NOT NULL($5), IS NOT NULL($17))])
HiveFilter(condition=[AND(IS NOT NULL($17), IS NOT NULL($5))])
HiveTableScan(table=[[default, store]], table:alias=[store])
HiveProject(i_item_sk=[$0], i_brand=[$8], i_category=[$12])
HiveFilter(condition=[AND(IS NOT NULL($12), IS NOT NULL($8))])
HiveFilter(condition=[AND(IS NOT NULL($8), IS NOT NULL($12))])
HiveTableScan(table=[[default, item]], table:alias=[item])

Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ HiveSortLimit(sort0=[$2], sort1=[$1], sort2=[$0], dir0=[ASC], dir1=[ASC], dir2=[
HiveFilter(condition=[AND(IS NOT NULL($6), IS NOT NULL($22))])
HiveTableScan(table=[[default, store_sales]], table:alias=[store_sales])
HiveProject(i_item_sk=[$0], i_manufact_id=[$13])
HiveFilter(condition=[AND(IN($10, _UTF-16LE'accessories', _UTF-16LE'classical', _UTF-16LE'fragrances', _UTF-16LE'pants', _UTF-16LE'personal', _UTF-16LE'portable', _UTF-16LE'reference', _UTF-16LE'self-help'), IN($12, _UTF-16LE'Books', _UTF-16LE'Children', _UTF-16LE'Electronics', _UTF-16LE'Men', _UTF-16LE'Music', _UTF-16LE'Women'), IN($8, _UTF-16LE'amalgimporto #1', _UTF-16LE'edu packscholar #1', _UTF-16LE'exportiimporto #1', _UTF-16LE'exportiunivamalg #9', _UTF-16LE'importoamalg #1', _UTF-16LE'scholaramalgamalg #14', _UTF-16LE'scholaramalgamalg #7', _UTF-16LE'scholaramalgamalg #9'), OR(AND(IN($12, _UTF-16LE'Books', _UTF-16LE'Children', _UTF-16LE'Electronics'), IN($10, _UTF-16LE'personal', _UTF-16LE'portable', _UTF-16LE'reference', _UTF-16LE'self-help'), IN($8, _UTF-16LE'exportiunivamalg #9', _UTF-16LE'scholaramalgamalg #14', _UTF-16LE'scholaramalgamalg #7', _UTF-16LE'scholaramalgamalg #9')), AND(IN($12, _UTF-16LE'Men', _UTF-16LE'Music', _UTF-16LE'Women'), IN($10, _UTF-16LE'accessories', _UTF-16LE'classical', _UTF-16LE'fragrances', _UTF-16LE'pants'), IN($8, _UTF-16LE'amalgimporto #1', _UTF-16LE'edu packscholar #1', _UTF-16LE'exportiimporto #1', _UTF-16LE'importoamalg #1'))))])
HiveFilter(condition=[AND(IN($10, _UTF-16LE'accessories', _UTF-16LE'classical', _UTF-16LE'fragrances', _UTF-16LE'pants', _UTF-16LE'personal', _UTF-16LE'portable', _UTF-16LE'reference', _UTF-16LE'self-help'), IN($8, _UTF-16LE'amalgimporto #1', _UTF-16LE'edu packscholar #1', _UTF-16LE'exportiimporto #1', _UTF-16LE'exportiunivamalg #9', _UTF-16LE'importoamalg #1', _UTF-16LE'scholaramalgamalg #14', _UTF-16LE'scholaramalgamalg #7', _UTF-16LE'scholaramalgamalg #9'), IN($12, _UTF-16LE'Books', _UTF-16LE'Children', _UTF-16LE'Electronics', _UTF-16LE'Men', _UTF-16LE'Music', _UTF-16LE'Women'), OR(AND(IN($12, _UTF-16LE'Books', _UTF-16LE'Children', _UTF-16LE'Electronics'), IN($10, _UTF-16LE'personal', _UTF-16LE'portable', _UTF-16LE'reference', _UTF-16LE'self-help'), IN($8, _UTF-16LE'exportiunivamalg #9', _UTF-16LE'scholaramalgamalg #14', _UTF-16LE'scholaramalgamalg #7', _UTF-16LE'scholaramalgamalg #9')), AND(IN($12, _UTF-16LE'Men', _UTF-16LE'Music', _UTF-16LE'Women'), IN($10, _UTF-16LE'accessories', _UTF-16LE'classical', _UTF-16LE'fragrances', _UTF-16LE'pants'), IN($8, _UTF-16LE'amalgimporto #1', _UTF-16LE'edu packscholar #1', _UTF-16LE'exportiimporto #1', _UTF-16LE'importoamalg #1'))))])
HiveTableScan(table=[[default, item]], table:alias=[item])
HiveProject(d_date_sk=[$0], d_qoy=[$10])
HiveFilter(condition=[IN($3, 1212, 1213, 1214, 1215, 1216, 1217, 1218, 1219, 1220, 1221, 1222, 1223)])
Expand Down
Loading