Pig TOBAG 函数

• 

  TOBAG 函数

  Pig-Latin TOBAG()函数将一个或多个表达式转换为单个元组。然后将这些元组放在袋子中。

  句法

  下面给出的是TOBAG（）函数的语法。

  
  TOBAG(expression [, expression ...])
  

  复制

  例子

  假设我们在HDFS目录/pig_data/中有一个名为employee_details.txt的文件，内容如下。

  
  001,Robin,22,newyork
  002,BOB,23,Kolkata
  003,Maya,23,Tokyo 
  004,Sara,25,London 
  005,David,23,Bhuwaneshwar 
  006,Maggy,22,Chennai
  

  复制

  我们已将该文件以关系名称emp_data加载到Pig中，如下所示。

  
  grunt> emp_data = LOAD 'hdfs://localhost:9000/pig_data/employee_details.txt' USING PigStorage(',')
     as (id:int, name:chararray, age:int, city:chararray);
  

  复制

  现在，让我们将每个员工（记录）的ID，姓名，年龄和城市转换为元组，如下所示。

  
  tobag = FOREACH emp_data GENERATE TOBAG (id,name,age,city);
  

  复制

  验证

  您可以使用Dump运算符验证tobag关系的内容，如下所示。

  
  grunt> DUMP tobag;
    
  ({(1),(Robin),(22),(newyork)}) 
  ({(2),(BOB),(23),(Kolkata)}) 
  ({(3),(Maya),(23),(Tokyo)}) 
  ({(4),(Sara),(25),(London)}) 
  ({(5),(David),(23),(Bhuwaneshwar)}) 
  ({(6),(Maggy),(22),(Chennai)})
  

  复制