sqlContext.sql(<query>).map(row=> ((row.getString(0), row.getString(1)),row.getInt(2)))
On Wed, Nov 4, 2015 at 1:44 PM, pratik khadloya <tispra...@gmail.com> wrote: > Hello, > > Is it possible to have a pair RDD from the below SQL query. > The pair being ((item_id, flight_id), metric1) > > item_id, flight_id are part of group by. > > SELECT > item_id, > flight_id, > SUM(metric1) AS metric1 > FROM mytable > GROUP BY > item_id, > flight_id > > > Thanks, > Pratik >
