使用Spark Core改写SQL语句实现的功能

对于一张数据表,以下图所示java 对上述表实现分组统计查询: select pageid,age,count(1) from pv_users group by pageid,age;apache 将上述的SQL查询语句改写成Spark的代码,以下:oop package com.company.sparkcore import org.apache.spark.{SparkConf, Spa
相关文章
相关标签/搜索