Please fine the query plan
scala> sqlContext.sql("SELECT dw.DAY_OF_WEEK, dw.HOUR, avg(dw.SDP_USAGE) AS
AVG_SDP_USAGE FROM (SELECT sdp.WID, DAY_OF_WEEK, HOUR, SUM(INTERVAL_VALUE)
AS SDP_USAGE FROM (SELECT * FROM date_d AS dd JOIN interval_f AS intf ON
intf.DATE_WID = dd.WID WHERE intf.DATE_WID >= 2
Dude,
please, attach the execution plan of the query and details about the
indexes.
2015-03-06 9:07 GMT-03:00 anu :
> I have a query that's like:
>
> Could you help in providing me pointers as to how to start to optimize it
> w.r.t. spark sql:
>
>
> sqlContext.sql("
>
> SELECT dw.DAY_OF_WEEK,
