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-1655) Cannot plan simple join + group by + order + limit query
Date Mon, 26 Jan 2015 21:18:34 GMT

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

Jinfeng Ni updated DRILL-1655:
------------------------------
    Attachment: 0001-DRILL-1655-Fix-CanNotPlan-issue-when-join-Mongodb-an.patch

> Cannot plan simple join + group by + order  + limit query
> ---------------------------------------------------------
>
>                 Key: DRILL-1655
>                 URL: https://issues.apache.org/jira/browse/DRILL-1655
>             Project: Apache Drill
>          Issue Type: Bug
>          Components: Query Planning & Optimization
>            Reporter: Tomer Shiran
>            Assignee: Jinfeng Ni
>             Fix For: 0.8.0
>
>         Attachments: 0001-DRILL-1655-Fix-CanNotPlan-issue-when-join-Mongodb-an.patch
>
>
> The first query here works fine. As soon as I add another field (avg(u.average_stars)
as stars) and order by on that field, it no longer works.
> {code}
> 0: jdbc:drill:zk=local> select u.name, n.gender, count(*) as number from mongo.yelp.users
u, dfs.mydata.namegender n where u.name = n.name group by u.name, n.gender order by number
desc limit 1;
> +------------+------------+------------+
> |    name    |   gender   |   number   |
> +------------+------------+------------+
> | David      | Male       | 2453       |
> +------------+------------+------------+
> 1 row selected (6.008 seconds)
> 0: jdbc:drill:zk=local> select u.name, n.gender, count(*) as number, avg(u.average_stars)
stars from mongo.yelp.users u, dfs.mydata.namegender n where u.name = n.name group by u.name,
n.gender order by stars desc limit 1;
> Query failed: Failure while parsing sql. Node [rel#38935:Subset#7.LOGICAL.ANY([]).[3
DESC]] could not be implemented; planner state:
> Root: rel#38935:Subset#7.LOGICAL.ANY([]).[3 DESC]
> Original rel:
> AbstractConverter(subset=[rel#38935:Subset#7.LOGICAL.ANY([]).[3 DESC]], convention=[LOGICAL],
DrillDistributionTraitDef=[ANY([])], sort=[[3 DESC]]): rowcount = 1.7976931348623157E308,
cumulative cost = {inf}, id = 38936
>   SortRel(subset=[rel#38934:Subset#7.NONE.ANY([]).[3 DESC]], sort0=[$3], dir0=[DESC],
fetch=[1]): rowcount = 1.7976931348623157E308, cumulative cost = {Infinity rows, 1.7976931348623157E308
cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 38933
>     AggregateRel(subset=[rel#38932:Subset#6.NONE.ANY([]).[]], group=[{0, 1}], number=[COUNT()],
stars=[AVG($2)]): rowcount = 1.7976931348623158E307, cumulative cost = {1.7976931348623158E307
rows, 0.0 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 38931
>       ProjectRel(subset=[rel#38930:Subset#5.NONE.ANY([]).[]], name=[$1], gender=[$3],
name0=[$2]): rowcount Error: exception while executing query: Failure while trying to get
next result batch. (state=,code=0)
> = 1.7976931348623157E308, cumulative cost = {1.7976931348623157E308 rows, Infinity cpu,
0.0 io, 0.0 network, 0.0 memory}, id = 38929
>         FilterRel(subset=[rel#38928:Subset#4.NONE.ANY([]).[]], condition=[=($1, $2)]):
rowcount = 2.6965397022934733E307, cumulative cost = {2.6965397022934733E307 rows, 1.7976931348623157E308
cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 38927
>           JoinRel(subset=[rel#38926:Subset#3.NONE.ANY([]).[]], condition=[true], joinType=[inner]):
rowcount = 1.7976931348623157E308, cumulative cost = {1.7976931348623157E308 rows, 0.0 cpu,
0.0 io, 0.0 network, 0.0 memory}, id = 38925
>             EnumerableTableAccessRel(subset=[rel#38921:Subset#0.ENUMERABLE.ANY([]).[]],
table=[[mongo, yelp, users]]): rowcount = 100.0, cumulative cost = {100.0 rows, 101.0 cpu,
0.0 io, 0.0 network, 0.0 memory}, id = 38897
>             ProjectRel(subset=[rel#38924:Subset#2.NONE.ANY([]).[]], name=[ITEM($1, 0)],
gender=[ITEM($1, 4)]): rowcount = 100.0, cumulative cost = {100.0 rows, 200.0 cpu, 0.0 io,
0.0 network, 0.0 memory}, id = 38923
>               EnumerableTableAccessRel(subset=[rel#38922:Subset#1.ENUMERABLE.ANY([]).[]],
table=[[dfs, mydata, names.csv]]): rowcount = 100.0, cumulative cost = {100.0 rows, 101.0
cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 38900
> Sets:
> Set#0, type: (DrillRecordRow[*, name, average_stars])
> 	rel#38921:Subset#0.ENUMERABLE.ANY([]).[], best=rel#38897, importance=0.531441
> 		rel#38897:EnumerableTableAccessRel.ENUMERABLE.ANY([]).[](table=[mongo, yelp, users]),
rowcount=100.0, cumulative cost={100.0 rows, 101.0 cpu, 0.0 io, 0.0 network, 0.0 memory}
> 		rel#38979:AbstractConverter.ENUMERABLE.ANY([]).[](child=rel#38978:Subset#0.LOGICAL.ANY([]).[],convention=ENUMERABLE,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=252898.0, cumulative cost={inf}
> 	rel#38978:Subset#0.LOGICAL.ANY([]).[], best=rel#39094, importance=0.4782969000000001
> 		rel#38980:AbstractConverter.LOGICAL.ANY([]).[](child=rel#38921:Subset#0.ENUMERABLE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=100.0, cumulative cost={inf}
> 		rel#39094:DrillScanRel.LOGICAL.ANY([]).[](table=[mongo, yelp, users],groupscan=MongoGroupScan
[MongoScanSpec=MongoScanSpec [dbName=yelp, collectionName=users, filters=null], columns=[SchemaPath
[`*`]]]), rowcount=252898.0, cumulative cost={252898.0 rows, 2.52898E9 cpu, 0.0 io, 0.0 network,
0.0 memory}
> Set#1, type: (DrillRecordRow[*, columns])
> 	rel#38922:Subset#1.ENUMERABLE.ANY([]).[], best=rel#38900, importance=0.4782969000000001
> 		rel#38900:EnumerableTableAccessRel.ENUMERABLE.ANY([]).[](table=[dfs, mydata, names.csv]),
rowcount=100.0, cumulative cost={100.0 rows, 101.0 cpu, 0.0 io, 0.0 network, 0.0 memory}
> 		rel#39068:AbstractConverter.ENUMERABLE.ANY([]).[](child=rel#39067:Subset#1.LOGICAL.ANY([]).[],convention=ENUMERABLE,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=5710.0, cumulative cost={inf}
> 	rel#39067:Subset#1.LOGICAL.ANY([]).[], best=rel#39095, importance=0.4304672100000001
> 		rel#39069:AbstractConverter.LOGICAL.ANY([]).[](child=rel#38922:Subset#1.ENUMERABLE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=100.0, cumulative cost={inf}
> 		rel#39095:DrillScanRel.LOGICAL.ANY([]).[](table=[dfs, mydata, names.csv],groupscan=EasyGroupScan
[selectionRoot=/Users/tshiran/Development/data/names.csv, numFiles=1, columns = [SchemaPath
[`*`]]]), rowcount=5710.0, cumulative cost={5710.0 rows, 5.71E7 cpu, 0.0 io, 0.0 network,
0.0 memory}
> Set#2, type: RecordType(ANY name, ANY gender)
> 	rel#38924:Subset#2.NONE.ANY([]).[], best=null, importance=0.531441
> 		rel#38923:ProjectRel.NONE.ANY([]).[](child=rel#38922:Subset#1.ENUMERABLE.ANY([]).[],name=ITEM($1,
0),gender=ITEM($1, 4)), rowcount=100.0, cumulative cost={inf}
> 	rel#38981:Subset#2.LOGICAL.ANY([]).[], best=rel#39033, importance=0.4782969000000001
> 		rel#38982:AbstractConverter.LOGICAL.ANY([]).[](child=rel#38924:Subset#2.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39033:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#39032:Subset#18.LOGICAL.ANY([]).[],name=ITEM($0,
0),gender=ITEM($0, 4)), rowcount=5710.0, cumulative cost={11420.0 rows, 5718.0 cpu, 0.0 io,
0.0 network, 0.0 memory}
> 		rel#39075:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#39067:Subset#1.LOGICAL.ANY([]).[],name=ITEM($1,
0),gender=ITEM($1, 4)), rowcount=5710.0, cumulative cost={11420.0 rows, 5.7100008E7 cpu, 0.0
io, 0.0 network, 0.0 memory}
> Set#3, type: RecordType(ANY *, ANY name, ANY average_stars, ANY name0, ANY gender)
> 	rel#38926:Subset#3.NONE.ANY([]).[], best=null, importance=0.5904900000000001
> 		rel#38925:JoinRel.NONE.ANY([]).[](left=rel#38921:Subset#0.ENUMERABLE.ANY([]).[],right=rel#38924:Subset#2.NONE.ANY([]).[],condition=true,joinType=inner),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 	rel#38984:Subset#3.LOGICAL.ANY([]).[], best=null, importance=0.4782969000000001
> 		rel#38985:AbstractConverter.LOGICAL.ANY([]).[](child=rel#38926:Subset#3.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#38983:DrillJoinRel.LOGICAL.ANY([]).[](left=rel#38978:Subset#0.LOGICAL.ANY([]).[],right=rel#38981:Subset#2.LOGICAL.ANY([]).[],condition=true,joinType=inner),
rowcount=252898.0, cumulative cost={inf}
> Set#4, type: RecordType(ANY *, ANY name, ANY average_stars, ANY name0, ANY gender)
> 	rel#38928:Subset#4.NONE.ANY([]).[], best=null, importance=0.6561
> 		rel#38927:FilterRel.NONE.ANY([]).[](child=rel#38926:Subset#3.NONE.ANY([]).[],condition==($1,
$2)), rowcount=2.6965397022934733E307, cumulative cost={inf}
> 		rel#38995:JoinRel.NONE.ANY([]).[](left=rel#38994:Subset#12.NONE.ANY([]).[],right=rel#38924:Subset#2.NONE.ANY([]).[],condition=true,joinType=inner),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 	rel#38973:Subset#4.LOGICAL.ANY([]).[], best=null, importance=0.531441
> 		rel#38974:AbstractConverter.LOGICAL.ANY([]).[](child=rel#38928:Subset#4.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39037:DrillJoinRel.LOGICAL.ANY([]).[](left=rel#39035:Subset#12.LOGICAL.ANY([]).[],right=rel#38981:Subset#2.LOGICAL.ANY([]).[],condition=true,joinType=inner),
rowcount=37934.7, cumulative cost={inf}
> 		rel#39059:DrillFilterRel.LOGICAL.ANY([]).[](child=rel#38984:Subset#3.LOGICAL.ANY([]).[],condition==($1,
$2)), rowcount=2.6965397022934733E307, cumulative cost={inf}
> Set#5, type: RecordType(ANY name, ANY gender, ANY name0)
> 	rel#38930:Subset#5.NONE.ANY([]).[], best=null, importance=0.7290000000000001
> 		rel#38929:ProjectRel.NONE.ANY([]).[](child=rel#38928:Subset#4.NONE.ANY([]).[],name=$1,gender=$3,name0=$2),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#38961:ProjectRel.NONE.ANY([]).[](child=rel#38960:Subset#11.NONE.ANY([]).[],name=$0,gender=$2,name0=$1),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#38970:ProjectRel.NONE.ANY([]).[](child=rel#38928:Subset#4.NONE.ANY([]).[],name=$1,gender=$3,name0=$2),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 	rel#38942:Subset#5.LOGICAL.ANY([]).[], best=null, importance=0.6561
> 		rel#38943:AbstractConverter.LOGICAL.ANY([]).[](child=rel#38930:Subset#5.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39034:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#38976:Subset#11.LOGICAL.ANY([]).[],name=$0,gender=$2,name0=$1),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39038:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#38973:Subset#4.LOGICAL.ANY([]).[],name=$1,gender=$3,name0=$2),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39058:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#38973:Subset#4.LOGICAL.ANY([]).[],name=$1,gender=$3,name0=$2),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> Set#6, type: RecordType(ANY name, ANY gender, BIGINT number, ANY stars)
> 	rel#38932:Subset#6.NONE.ANY([]).[], best=null, importance=0.81
> 		rel#38931:AggregateRel.NONE.ANY([]).[](child=rel#38930:Subset#5.NONE.ANY([]).[],group={0,
1},number=COUNT(),stars=AVG($2)), rowcount=1.7976931348623158E307, cumulative cost={inf}
> 		rel#38950:ProjectRel.NONE.ANY([]).[](child=rel#38949:Subset#9.NONE.ANY([]).[],name=$0,gender=$1,number=$2,stars=CAST(/(CastHigh(CASE(=($2,
0), null, $3)), $2)):ANY), rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39085:AbstractConverter.NONE.ANY([]).[3 DESC](child=rel#38932:Subset#6.NONE.ANY([]).[],convention=NONE,DrillDistributionTraitDef=ANY([]),sort=[3
DESC]), rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39086:AbstractConverter.NONE.ANY([]).[3 DESC](child=rel#38945:Subset#6.LOGICAL.ANY([]).[],convention=NONE,DrillDistributionTraitDef=ANY([]),sort=[3
DESC]), rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39087:AbstractConverter.NONE.ANY([]).[3 DESC](child=rel#39078:Subset#6.LOGICAL.ANY([]).[3
DESC],convention=NONE,DrillDistributionTraitDef=ANY([]),sort=[3 DESC]), rowcount=1.7976931348623157E308,
cumulative cost={inf}
> 		rel#38937:SortRel.NONE.ANY([]).[3 DESC](child=rel#38932:Subset#6.NONE.ANY([]).[],sort0=$3,dir0=DESC),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39089:SortRel.NONE.ANY([]).[3 DESC](child=rel#38945:Subset#6.LOGICAL.ANY([]).[],sort0=$3,dir0=DESC),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 	rel#38945:Subset#6.LOGICAL.ANY([]).[], best=null, importance=0.7290000000000001
> 		rel#38946:AbstractConverter.LOGICAL.ANY([]).[](child=rel#38932:Subset#6.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#38944:DrillAggregateRel.LOGICAL.ANY([]).[](child=rel#38942:Subset#5.LOGICAL.ANY([]).[],group={0,
1},number=COUNT(),stars=AVG($2)), rowcount=1.7976931348623158E307, cumulative cost={inf}
> 		rel#38953:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#38951:Subset#9.LOGICAL.ANY([]).[],name=$0,gender=$1,number=$2,stars=CAST(/(CastHigh(CASE(=($2,
0), null, $3)), $2)):ANY), rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39079:AbstractConverter.LOGICAL.ANY([]).[](child=rel#39078:Subset#6.LOGICAL.ANY([]).[3
DESC],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]), rowcount=1.7976931348623157E308,
cumulative cost={inf}
> 		rel#39080:AbstractConverter.LOGICAL.ANY([]).[3 DESC](child=rel#38932:Subset#6.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[3
DESC]), rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39081:AbstractConverter.LOGICAL.ANY([]).[3 DESC](child=rel#38945:Subset#6.LOGICAL.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[3
DESC]), rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39083:AbstractConverter.LOGICAL.ANY([]).[](child=rel#39082:Subset#6.NONE.ANY([]).[3
DESC],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]), rowcount=1.7976931348623157E308,
cumulative cost={inf}
> 		rel#39084:AbstractConverter.LOGICAL.ANY([]).[3 DESC](child=rel#39082:Subset#6.NONE.ANY([]).[3
DESC],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[3 DESC]), rowcount=1.7976931348623157E308,
cumulative cost={inf}
> 		rel#39077:DrillSortRel.LOGICAL.ANY([]).[3 DESC](child=rel#38945:Subset#6.LOGICAL.ANY([]).[],sort0=$3,dir0=DESC),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 	rel#39078:Subset#6.LOGICAL.ANY([]).[3 DESC], best=null, importance=0.6561
> 		rel#39080:AbstractConverter.LOGICAL.ANY([]).[3 DESC](child=rel#38932:Subset#6.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[3
DESC]), rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39081:AbstractConverter.LOGICAL.ANY([]).[3 DESC](child=rel#38945:Subset#6.LOGICAL.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[3
DESC]), rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39084:AbstractConverter.LOGICAL.ANY([]).[3 DESC](child=rel#39082:Subset#6.NONE.ANY([]).[3
DESC],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[3 DESC]), rowcount=1.7976931348623157E308,
cumulative cost={inf}
> 		rel#39077:DrillSortRel.LOGICAL.ANY([]).[3 DESC](child=rel#38945:Subset#6.LOGICAL.ANY([]).[],sort0=$3,dir0=DESC),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 	rel#39082:Subset#6.NONE.ANY([]).[3 DESC], best=null, importance=0.5904900000000001
> 		rel#39085:AbstractConverter.NONE.ANY([]).[3 DESC](child=rel#38932:Subset#6.NONE.ANY([]).[],convention=NONE,DrillDistributionTraitDef=ANY([]),sort=[3
DESC]), rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39086:AbstractConverter.NONE.ANY([]).[3 DESC](child=rel#38945:Subset#6.LOGICAL.ANY([]).[],convention=NONE,DrillDistributionTraitDef=ANY([]),sort=[3
DESC]), rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39087:AbstractConverter.NONE.ANY([]).[3 DESC](child=rel#39078:Subset#6.LOGICAL.ANY([]).[3
DESC],convention=NONE,DrillDistributionTraitDef=ANY([]),sort=[3 DESC]), rowcount=1.7976931348623157E308,
cumulative cost={inf}
> 		rel#38937:SortRel.NONE.ANY([]).[3 DESC](child=rel#38932:Subset#6.NONE.ANY([]).[],sort0=$3,dir0=DESC),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39089:SortRel.NONE.ANY([]).[3 DESC](child=rel#38945:Subset#6.LOGICAL.ANY([]).[],sort0=$3,dir0=DESC),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> Set#7, type: RecordType(ANY name, ANY gender, BIGINT number, ANY stars)
> 	rel#38934:Subset#7.NONE.ANY([]).[3 DESC], best=null, importance=0.9
> 		rel#38933:SortRel.NONE.ANY([]).[3 DESC](child=rel#38932:Subset#6.NONE.ANY([]).[],sort0=$3,dir0=DESC,fetch=1),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 	rel#38935:Subset#7.LOGICAL.ANY([]).[3 DESC], best=null, importance=1.0
> 		rel#38936:AbstractConverter.LOGICAL.ANY([]).[3 DESC](child=rel#38934:Subset#7.NONE.ANY([]).[3
DESC],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[3 DESC]), rowcount=1.7976931348623157E308,
cumulative cost={inf}
> 		rel#38941:DrillLimitRel.LOGICAL.ANY([]).[3 DESC](child=rel#39078:Subset#6.LOGICAL.ANY([]).[3
DESC],fetch=1), rowcount=1.7976931348623157E308, cumulative cost={inf}
> Set#9, type: RecordType(ANY name, ANY gender, BIGINT number, ANY $f3)
> 	rel#38949:Subset#9.NONE.ANY([]).[], best=null, importance=0.7290000000000001
> 		rel#38947:AggregateRel.NONE.ANY([]).[](child=rel#38930:Subset#5.NONE.ANY([]).[],group={0,
1},number=COUNT(),agg#1=$SUM0($2)), rowcount=1.7976931348623158E307, cumulative cost={inf}
> 	rel#38951:Subset#9.LOGICAL.ANY([]).[], best=null, importance=0.6561
> 		rel#38952:AbstractConverter.LOGICAL.ANY([]).[](child=rel#38949:Subset#9.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#38954:DrillAggregateRel.LOGICAL.ANY([]).[](child=rel#38942:Subset#5.LOGICAL.ANY([]).[],group={0,
1},number=COUNT(),agg#1=$SUM0($2)), rowcount=1.7976931348623158E307, cumulative cost={inf}
> Set#10, type: RecordType(ANY name, ANY average_stars, ANY name0)
> 	rel#38958:Subset#10.NONE.ANY([]).[], best=null, importance=0.5904900000000001
> 		rel#38955:ProjectRel.NONE.ANY([]).[](child=rel#38926:Subset#3.NONE.ANY([]).[],name=$1,average_stars=$2,name0=$3),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39018:JoinRel.NONE.ANY([]).[](left=rel#39017:Subset#16.NONE.ANY([]).[],right=rel#39001:Subset#14.NONE.ANY([]).[],condition=true,joinType=inner),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 	rel#39011:Subset#10.LOGICAL.ANY([]).[], best=null, importance=0.531441
> 		rel#39012:AbstractConverter.LOGICAL.ANY([]).[](child=rel#38958:Subset#10.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39055:DrillJoinRel.LOGICAL.ANY([]).[](left=rel#39047:Subset#16.LOGICAL.ANY([]).[],right=rel#39053:Subset#14.LOGICAL.ANY([]).[],condition=true,joinType=inner),
rowcount=252898.0, cumulative cost={inf}
> 		rel#39057:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#38984:Subset#3.LOGICAL.ANY([]).[],name=$1,average_stars=$2,name0=$3),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> Set#11, type: RecordType(ANY name, ANY average_stars, ANY name0)
> 	rel#38960:Subset#11.NONE.ANY([]).[], best=null, importance=0.6561
> 		rel#38959:FilterRel.NONE.ANY([]).[](child=rel#38958:Subset#10.NONE.ANY([]).[],condition==($0,
$1)), rowcount=2.6965397022934733E307, cumulative cost={inf}
> 		rel#38966:ProjectRel.NONE.ANY([]).[](child=rel#38928:Subset#4.NONE.ANY([]).[],name=$1,average_stars=$2,name0=$3),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39002:JoinRel.NONE.ANY([]).[](left=rel#39000:Subset#13.NONE.ANY([]).[],right=rel#39001:Subset#14.NONE.ANY([]).[],condition=true,joinType=inner),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 	rel#38976:Subset#11.LOGICAL.ANY([]).[], best=null, importance=0.5904900000000001
> 		rel#38977:AbstractConverter.LOGICAL.ANY([]).[](child=rel#38960:Subset#11.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#38975:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#38973:Subset#4.LOGICAL.ANY([]).[],name=$1,average_stars=$2,name0=$3),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39013:DrillFilterRel.LOGICAL.ANY([]).[](child=rel#39011:Subset#10.LOGICAL.ANY([]).[],condition==($0,
$1)), rowcount=2.6965397022934733E307, cumulative cost={inf}
> 		rel#39071:DrillJoinRel.LOGICAL.ANY([]).[](left=rel#39051:Subset#13.LOGICAL.ANY([]).[],right=rel#39053:Subset#14.LOGICAL.ANY([]).[],condition=true,joinType=inner),
rowcount=37934.7, cumulative cost={inf}
> Set#12, type: (DrillRecordRow[*, name, average_stars])
> 	rel#38994:Subset#12.NONE.ANY([]).[], best=null, importance=0.5904900000000001
> 		rel#38991:FilterRel.NONE.ANY([]).[](child=rel#38921:Subset#0.ENUMERABLE.ANY([]).[],condition==($1,
$2)), rowcount=15.0, cumulative cost={inf}
> 	rel#39035:Subset#12.LOGICAL.ANY([]).[], best=rel#39056, importance=0.4782969000000001
> 		rel#39036:AbstractConverter.LOGICAL.ANY([]).[](child=rel#38994:Subset#12.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39056:DrillFilterRel.LOGICAL.ANY([]).[](child=rel#38978:Subset#0.LOGICAL.ANY([]).[],condition==($1,
$2)), rowcount=37934.7, cumulative cost={505796.0 rows, 2.529991592E9 cpu, 0.0 io, 0.0 network,
0.0 memory}
> Set#13, type: RecordType(ANY name, ANY average_stars)
> 	rel#39000:Subset#13.NONE.ANY([]).[], best=null, importance=0.5904900000000001
> 		rel#38996:ProjectRel.NONE.ANY([]).[](child=rel#38994:Subset#12.NONE.ANY([]).[],name=$1,average_stars=$2),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39019:FilterRel.NONE.ANY([]).[](child=rel#39017:Subset#16.NONE.ANY([]).[],condition==($0,
$1)), rowcount=2.6965397022934733E307, cumulative cost={inf}
> 	rel#39051:Subset#13.LOGICAL.ANY([]).[], best=rel#39050, importance=0.531441
> 		rel#39052:AbstractConverter.LOGICAL.ANY([]).[](child=rel#39000:Subset#13.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39050:DrillFilterRel.LOGICAL.ANY([]).[](child=rel#39047:Subset#16.LOGICAL.ANY([]).[],condition==($0,
$1)), rowcount=37934.7, cumulative cost={758694.0 rows, 1517396.0 cpu, 0.0 io, 0.0 network,
0.0 memory}
> 		rel#39074:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#39035:Subset#12.LOGICAL.ANY([]).[],name=$1,average_stars=$2),
rowcount=37934.7, cumulative cost={543730.7 rows, 2.5299916E9 cpu, 0.0 io, 0.0 network, 0.0
memory}
> Set#14, type: RecordType(ANY name)
> 	rel#39001:Subset#14.NONE.ANY([]).[], best=null, importance=0.531441
> 		rel#38997:ProjectRel.NONE.ANY([]).[](child=rel#38924:Subset#2.NONE.ANY([]).[],name=$0),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39049:ProjectRel.NONE.ANY([]).[](child=rel#38922:Subset#1.ENUMERABLE.ANY([]).[],name=ITEM($1,
0)), rowcount=100.0, cumulative cost={inf}
> 	rel#39053:Subset#14.LOGICAL.ANY([]).[], best=rel#39063, importance=0.4782969000000001
> 		rel#39054:AbstractConverter.LOGICAL.ANY([]).[](child=rel#39001:Subset#14.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39063:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#39062:Subset#20.LOGICAL.ANY([]).[],name=ITEM($0,
0)), rowcount=5710.0, cumulative cost={11420.0 rows, 5714.0 cpu, 0.0 io, 0.0 network, 0.0
memory}
> 		rel#39070:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#39067:Subset#1.LOGICAL.ANY([]).[],name=ITEM($1,
0)), rowcount=5710.0, cumulative cost={11420.0 rows, 5.7100004E7 cpu, 0.0 io, 0.0 network,
0.0 memory}
> 		rel#39073:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#38981:Subset#2.LOGICAL.ANY([]).[],name=$0),
rowcount=5710.0, cumulative cost={17130.0 rows, 5722.0 cpu, 0.0 io, 0.0 network, 0.0 memory}
> Set#16, type: RecordType(ANY name, ANY average_stars)
> 	rel#39017:Subset#16.NONE.ANY([]).[], best=null, importance=0.531441
> 		rel#39014:ProjectRel.NONE.ANY([]).[](child=rel#38921:Subset#0.ENUMERABLE.ANY([]).[],name=$1,average_stars=$2),
rowcount=100.0, cumulative cost={inf}
> 	rel#39047:Subset#16.LOGICAL.ANY([]).[], best=rel#39046, importance=0.4782969000000001
> 		rel#39048:AbstractConverter.LOGICAL.ANY([]).[](child=rel#39017:Subset#16.NONE.ANY([]).[],convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.7976931348623157E308, cumulative cost={inf}
> 		rel#39046:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#39045:Subset#19.LOGICAL.ANY([]).[],name=$1,average_stars=$0),
rowcount=252898.0, cumulative cost={505796.0 rows, 505804.0 cpu, 0.0 io, 0.0 network, 0.0
memory}
> 		rel#39072:DrillProjectRel.LOGICAL.ANY([]).[](child=rel#38978:Subset#0.LOGICAL.ANY([]).[],name=$1,average_stars=$2),
rowcount=252898.0, cumulative cost={505796.0 rows, 2.528980008E9 cpu, 0.0 io, 0.0 network,
0.0 memory}
> Set#18, type: RecordType(ANY columns)
> 	rel#39032:Subset#18.LOGICAL.ANY([]).[], best=rel#39030, importance=0.4304672100000001
> 		rel#39030:DrillScanRel.LOGICAL.ANY([]).[](table=[dfs, mydata, names.csv],groupscan=EasyGroupScan
[selectionRoot=/Users/tshiran/Development/data/names.csv, numFiles=1, columns = [SchemaPath
[`columns`[0]], SchemaPath [`columns`[4]]]]), rowcount=5710.0, cumulative cost={5710.0 rows,
5710.0 cpu, 0.0 io, 0.0 network, 0.0 memory}
> Set#19, type: RecordType(ANY average_stars, ANY name)
> 	rel#39045:Subset#19.LOGICAL.ANY([]).[], best=rel#39043, importance=0.4304672100000001
> 		rel#39043:DrillScanRel.LOGICAL.ANY([]).[](table=[mongo, yelp, users],groupscan=MongoGroupScan
[MongoScanSpec=MongoScanSpec [dbName=yelp, collectionName=users, filters=null], columns=[SchemaPath
[`name`], SchemaPath [`average_stars`]]]), rowcount=252898.0, cumulative cost={252898.0 rows,
505796.0 cpu, 0.0 io, 0.0 network, 0.0 memory}
> Set#20, type: RecordType(ANY columns)
> 	rel#39062:Subset#20.LOGICAL.ANY([]).[], best=rel#39060, importance=0.4304672100000001
> 		rel#39060:DrillScanRel.LOGICAL.ANY([]).[](table=[dfs, mydata, names.csv],groupscan=EasyGroupScan
[selectionRoot=/Users/tshiran/Development/data/names.csv, numFiles=1, columns = [SchemaPath
[`columns`[0]]]]), rowcount=5710.0, cumulative cost={5710.0 rows, 5710.0 cpu, 0.0 io, 0.0
network, 0.0 memory}
>  [43217377-548e-4d8c-8468-e0ff909e768a]
> 0: jdbc:drill:zk=local> 
> {code}



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

Mime
View raw message