Pig IsEmpty 函数
-
IsEmpty 函数
Pig-Latin IsEmpty() 函数用于检查bag或map是否为空。句法下面给出了IsEmpty() 函数的语法。例子假设我们在HDFS目录/pig_data/中有两个文件,分别是emp_sales.txt和emp_bonus.txt,如下所示。该emp_sales.txt包含销售部门的员工的细节和emp_bonus.txt包含员工详细谁得到奖金。emp_sales.txtemp_bonus.txt我们已经将这些文件加载到Pig中,它们的关系名称分别为emp_sales和emp_bonus。如下所示,使用COGROUP运算符使用键sno对emp_sales和emp_bonus关系的记录/元组进行分组。如下所示,使用DUMP运算符验证关系cogroup_data。COGROUP运算符根据年龄将每个关系中的元组分组。每组描绘一个特定的年龄值。例如,如果我们考虑结果的第一个元组,则将其按年龄22分组。它包含两个袋子,第一个袋子中包含第一个关系(年龄为student_details)中年龄为22的所有元组,第二个bag包含第二个关系中年龄为22的所有元组(在本例中为employee_details)。如果某个关系中没有年龄值为22的元组,则它返回一个空bag。 -
获取bag中的空集
让我们使用IsEmpty() 函数从emp_sales关系中的组中列出此类空bag。验证如下所示,使用DUMP运算符验证关系isempty_data。该emp_sales关系认为,不存在关系中的元组emp_bonus。