drill-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jinfeng Ni (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (DRILL-3210) Star is not expanded correctly in projection list when used with window function
Date Sat, 20 Jun 2015 01:18:00 GMT

     [ https://issues.apache.org/jira/browse/DRILL-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Jinfeng Ni updated DRILL-3210:
------------------------------
    Fix Version/s:     (was: 1.2.0)
                   1.1.0

> Star is not expanded correctly in projection list when used with window function
> --------------------------------------------------------------------------------
>
>                 Key: DRILL-3210
>                 URL: https://issues.apache.org/jira/browse/DRILL-3210
>             Project: Apache Drill
>          Issue Type: Bug
>          Components: Query Planning & Optimization
>    Affects Versions: 1.0.0
>            Reporter: Victoria Markman
>            Assignee: Jinfeng Ni
>              Labels: window_function
>             Fix For: 1.1.0
>
>
> Just star ...
> {code}
> 0: jdbc:drill:schema=dfs> select * , sum(a1) over (partition by b1) from t1;
> +-----------+-----------+-------------+-------+--------+--------+--------+---------+----------+
> | T124¦¦a1  | T124¦¦b1  |  T124¦¦c1   |  a1   |   b1   | w0$o0  | w0$o1  | EXPR$1
 | EXPR$10  |
> +-----------+-----------+-------------+-------+--------+--------+--------+---------+----------+
> | 1         | aaaaa     | 2015-01-01  | 1     | aaaaa  | 1      | 1      | 1       |
1        |
> | 2         | bbbbb     | 2015-01-02  | 2     | bbbbb  | 1      | 2      | 2       |
2        |
> | 3         | ccccc     | 2015-01-03  | 3     | ccccc  | 1      | 3      | 3       |
3        |
> | 5         | eeeee     | 2015-01-05  | 5     | eeeee  | 1      | 5      | 5       |
5        |
> | 6         | fffff     | 2015-01-06  | 6     | fffff  | 1      | 6      | 6       |
6        |
> | 7         | ggggg     | 2015-01-07  | 7     | ggggg  | 1      | 7      | 7       |
7        |
> | null      | hhhhh     | 2015-01-08  | null  | hhhhh  | 0      | 0      | null    |
null     |
> | 9         | iiiii     | null        | 9     | iiiii  | 1      | 9      | 9       |
9        |
> | 10        | jjjjj     | 2015-01-10  | 10    | jjjjj  | 1      | 10     | 10      |
10       |
> | 4         | null      | 2015-01-04  | 4     | null   | 1      | 4      | 4       |
4        |
> +-----------+-----------+-------------+-------+--------+--------+--------+---------+----------+
> 10 rows selected (0.163 seconds)
> {code}
> t1 with the star ...
> {code}
> 0: jdbc:drill:schema=dfs> select t1.* , sum(a1) over (partition by b1) from t1;
> +-----------+-----------+-------------+-------+--------+--------+--------+---------+----------+
> | T125¦¦a1  | T125¦¦b1  |  T125¦¦c1   |  a1   |   b1   | w0$o0  | w0$o1  | EXPR$1
 | EXPR$10  |
> +-----------+-----------+-------------+-------+--------+--------+--------+---------+----------+
> | 1         | aaaaa     | 2015-01-01  | 1     | aaaaa  | 1      | 1      | 1       |
1        |
> | 2         | bbbbb     | 2015-01-02  | 2     | bbbbb  | 1      | 2      | 2       |
2        |
> | 3         | ccccc     | 2015-01-03  | 3     | ccccc  | 1      | 3      | 3       |
3        |
> | 5         | eeeee     | 2015-01-05  | 5     | eeeee  | 1      | 5      | 5       |
5        |
> | 6         | fffff     | 2015-01-06  | 6     | fffff  | 1      | 6      | 6       |
6        |
> | 7         | ggggg     | 2015-01-07  | 7     | ggggg  | 1      | 7      | 7       |
7        |
> | null      | hhhhh     | 2015-01-08  | null  | hhhhh  | 0      | 0      | null    |
null     |
> | 9         | iiiii     | null        | 9     | iiiii  | 1      | 9      | 9       |
9        |
> | 10        | jjjjj     | 2015-01-10  | 10    | jjjjj  | 1      | 10     | 10      |
10       |
> | 4         | null      | 2015-01-04  | 4     | null   | 1      | 4      | 4       |
4        |
> +-----------+-----------+-------------+-------+--------+--------+--------+---------+----------+
> 10 rows selected (0.158 seconds)
> {code}
> Explain plan:
> {code}
> 0: jdbc:drill:schema=dfs> explain plan for select * , sum(a1) over (partition by b1)
from t1;
> +------+------+
> | text | json |
> +------+------+
> | 00-00    Screen
> 00-01      ProjectAllowDup(*=[$0], EXPR$1=[$1])
> 00-02        Project(*=[$0], EXPR$1=[CASE(>($3, 0), CAST($4):ANY, null)])
> 00-03          Window(window#0=[window(partition {2} order by [] range between UNBOUNDED
PRECEDING and UNBOUNDED FOLLOWING aggs [COUNT($1), $SUM0($1)])])
> 00-04            SelectionVectorRemover
> 00-05              Sort(sort0=[$2], dir0=[ASC])
> 00-06                Project(T126¦¦*=[$0], a1=[$1], b1=[$2])
> 00-07                  Scan(groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///drill/testdata/subqueries/t1]],
selectionRoot=/drill/testdata/subqueries/t1, numFiles=1, columns=[`*`]]])
> {code}
> Table schema:
> {code}
> 0: jdbc:drill:schema=dfs> select * from t1 limit 1;
> +-----+--------+-------------+
> | a1  |   b1   |     c1      |
> +-----+--------+-------------+
> | 1   | aaaaa  | 2015-01-01  |
> +-----+--------+-------------+
> 1 row selected (0.119 seconds)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message