技术原理

在Apache Pig中创建UDF的步骤

本文包含在Apache Pig中创建UDF所需的必要步骤。所有UDF都应该扩展一个Filter函数,并且必须包含一个名为exec的方法,该方法包含一个元组。这里应用的逻辑是,如果元组为空或零,它将给您一个布尔值:True或False。“isopage”用于检查给定的年龄是否正确。用户定义函数的逻辑是用Java代码编写的,JAR文件将在其中创建并导出。JAR文件稍后注册。这些JAR文件在加载时可以在Apache Pig的库文件中找到。

公共类isopage扩展了FilterFunc{ @覆盖 publicBoolean exec(元组元组)throwsIOException{ if(元组==空| |元组大小(0分){ 返回False; } 试试看{ 对象对象=元组.get(0); if(对象==空){ 返回False; } inti=(整数)对象; 如果(i==18 | | i==19 | | i==21 | | i==23 | | i==27){ 返回真值; }其他{ 返回False; } }捕获(ExecExceptione){ 痛觉异常(e); } } }怎么称呼猪的乳房?”

“创建UDF后,必须使用以下命令注册JAR文件。

寄存器myudf.jar文件; X=filter A by isopage(age);在Pig中创建UDF的步骤:

Apache Pig中有多个预定义函数。我们还可以创建自己的函数,即用户定义函数(UDF),Pig UDF是用Java编写的,这需要Pig库使用预定义的类。Apache Pig库Pig-0.8.0-cdh3u0-core.jar文件可以从internet上下载。

单击此处了解在HDFS模式下使用UDF创建Pig脚本的步骤。

有问题要问我们吗?在评论部分提到它们,我们会给你回复。

相关帖子:

Apache Pig脚本,UDF在HDFS模式下

在Apache Pig中的运算符:第1部分-关系运算符

在Apache Pig中的运算符:第2部分-诊断运算符

大数据和Hadoop培训

你也可能喜欢

发表评论

您的电子邮件地址不会被公开。 必填项已用 * 标注

提示:点击验证后方可评论!

插入图片
上海人工智能培训机构 投稿者
我还没有学会写个人说明!
最近文章
  • * 没有更多文章了
  • 热门搜索

    分类目录