【摘要】:2)定义makeStruct函数,传入销售额、折扣金额,将销售额、折扣金额组合成一个case class,将SalesDiscount case class作为函数结果返回。3)在sqlContext.udf中注册makeStruct的自定义函数,makeStruct_是偏函数,makeStruct函数中传入销售额、折扣金额,返回case class类。3)在临时表customerTable中执行查询操作,查询结构体,统计查询打印结果。在本地运行,结果如下所示。
函数名称:makeStruct。
函数功能:从顾客商品购买记录表CustomerTable中查询销售额,折扣金额信息,将销售金额及折扣金额组合在一起显示,将sales和discounts组合成SalesDiscount结构。
函数示例:
1)定义SalesDiscount case class,其成员变量为销售金额、折扣金额。
2)定义makeStruct函数,传入销售额、折扣金额,将销售额、折扣金额组合成一个case class,将SalesDiscount case class作为函数结果返回。(www.xing528.com)
3)在sqlContext.udf中注册makeStruct的自定义函数,makeStruct_是偏函数,makeStruct函数中传入销售额、折扣金额,返回case class类。
3)在临时表customerTable中执行查询操作,查询(销售金额、折扣金额)结构体,统计查询打印结果。
4)在临时表customerTable中执行查询,查询ID序号,(销售金额、折扣金额)结构体sd,子查询结果为d;然后再从子查询结果d中查询ID序号,(销售金额、折扣金额)结构体sd,统计查询打印结果。
在本地运行,结果如下所示。
免责声明:以上内容源自网络,版权归原作者所有,如有侵犯您的原创版权请告知,我们将尽快删除相关内容。