spark-shell用非sql API 改写 hql
当我们在spark-shell用scala写程序的时候,如何不嵌入sql来查询Hive呢?这里我们来举个例子:hql先来看下想要执行的sql,这里选用了TPC-DS中的query3: select /*+MAPJOIN(dt, item)*/ dt.d_year ,item.i_brand_id brand_id