spark-sql相关实践

给定数据： orders表： product表： priors表： 实现以下业务需求： 1.统计product被购买的数量： val productCnt = priors.groupBy("product_id").count() 2..统计product 被reordered的数量（再次购买） product_id做group by(聚合)，统计一下sum（reorder）的值 1）prior

>>阅读原文<<