Apache PIG中是否有任何条件IF运算符？

实际上，我正在写PIG脚本，并希望执行一组语句，如果其中一个条件满足。Apache PIG中是否有任何条件IF运算符？

我已经设置了一个变量并检查该变量的某个值。假设

if flag==0 then 
    A = LOAD 'file' using PigStorage() as (f1:int, ....); 
    B = ...; 
    C = ....; 
else 
    again some Pig Latin statements

我可以在PIG脚本中执行此操作吗？如果是，那我该怎么做？

谢谢。

我遇到了Pig Latin中的条件运算符，如（a == b？c1：c2）;。但是，我怎样才能插入大量的猪语句？ –

Bhavesh，你需要为它编写一个封装器。推荐的用于编写具有条件逻辑或循环结构的程序的方法是将Pig Latin嵌入另一种语言，如Python， JavaScript或Java，并从那里管理控制流。 – Nag

您可以围绕您的Pig脚本创建Python包装。请参阅文档中的Embedded Pig。

2013-07-16 07:44:33

猪是数据流语言而不是控制流。只有接近的构造是PIG split，但它非常有限。

您可以使用oozie及其decision结构与两个猪脚本。

2013-07-17 11:36:32 Fakrudeen

是的，Pig确实提供了一个if-then-else的结构，，但它并没有以你要求的方式使用。

猪的IF-THEN-ELSE用速记调用is an arithmetic operator“条件true_value：false_value”作为表达的一部分，如：

X = FOREACH A GENERATE f2, (f2==1?1:COUNT(B));

你必须已经加载了表A中做到这一点。要执行整个Pig语句的控制流程，您需要像Fakrudeen所建议的oozie之类的东西。

2013-09-30 17:10:28

这适用于基于正在处理的数据的条件，但不适用基于外部参数的条件/标志。 –

创建UDF（比如说，在Java），然后是嵌入到你的PIG脚本。在编写UDF后，您需要“注册”您生成的jar文件。

//（像这样），说你的Java UDF class是UDFCondition &生成的JAR文件是PigUDFCondition.jar，然后在PIG Code

寄存器PigUDFCondition.jar

X = foreach A generate UDFCondition(..flag...)

2013-12-02 07:27:31

从0.12版开始就有CASE声明。

2015-08-03 20:20:30 ganeshrj

这将如何帮助？你能通过一个例子来扩展你的答案吗？ – dakab

回答