scala - SQL queries in RDD -
i must operate rdd scala/spark methods , sql queries.
is possible operate rdd directly via sql queries?
the proposed ways (schemardd or dataframe) require memory leakage.
after such transformation have in memory 2 identical huge objects.
yes, in way, may able so. you'll need create own version of dataframe.
dataframe abstraction on rdds. nevertheless, joins, filters, etc. features find spark-sql optimized dataframes made on rdds first.
Comments
Post a Comment