udaf 函數使用例子

最近使用sparksql,需求是須要對一些非結構化的數據進行處理，具體的需求是：sql 1 相似{「」，「」}，合併此類數據，若是有相同的field，則把value累加，無則把field加入express 2 相似a,b,c ，須要聚合後累加去重統計字母出現的次數apache 3 string 類型的數據 實現累加json package com.dianyou import com.di

>>阅读原文<<