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

>>阅读原文<<