我需要通过一个在Pig自定义项的关系
articles = load x using ...; groupedArticles = udfs.MyUDF(articles);
这样的事情可能吗？有解决办法吗？谢谢
frebpwbc1#
我猜你的意思是把所有的领域都交给自由民主党？传递这种关系是没有意义的。在任何情况下，这取决于load语句的外观。如果将每个条目作为元组加载 load x using ... as (entry:(a:int, b:chararray, ...)) 你可以像这样把它传给自由民主党 groupedArticles = foreach articles generate udfs.MyUDF(entry) 将整行作为一个元组传递可能是最通用的方法，但是您必须在您的udf中处理一个通用元组。
load x using ... as (entry:(a:int, b:chararray, ...))
groupedArticles = foreach articles generate udfs.MyUDF(entry)
1条答案
按热度按时间frebpwbc1#
我猜你的意思是把所有的领域都交给自由民主党？传递这种关系是没有意义的。在任何情况下，这取决于load语句的外观。如果将每个条目作为元组加载
load x using ... as (entry:(a:int, b:chararray, ...))你可以像这样把它传给自由民主党groupedArticles = foreach articles generate udfs.MyUDF(entry)将整行作为一个元组传递可能是最通用的方法，但是您必须在您的udf中处理一个通用元组。