我使用的是spark-sql-2.4.3v。我在一个场景中查找包含number-->值的广播变量Map。此Map以日期为基础,例如每月第一天,即2016-01-01。我创建了udf来查找这个Map,即udf(number)->(string)。我合并了源数据集,现在我在数据集中有多个月的第一个日期,即2016-01-01、2016-02-01、2016-03-01、2016-04-01、2016-05-01。现在我需要根据每个月给定的日期用广播变量Map来构造udf?
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!