pig的dbstorage不能与其他存储函数一起工作

dpiehjr4  于 2021-06-04  发布在  Hadoop
关注(0)|答案(0)|浏览(176)

dbstorage不能与pig脚本中的其他存储一起使用。表示dbstorage不能与multiple storage语句一起使用。
我尝试的是:1)我尝试使用dbstorage存储一个输出,并尝试使用simple store to file system存储相同或不同的输出2)我还尝试使用dbstorage和自定义store函数存储
但在这两种情况下,它都没有将数据存储到数据库中。如果我注解出dbstorage以外的其他存储正常工作。
即使它没有在减速机上抛出任何异常或错误。。
有人能指出这个问题吗?
dbstorage不适用于简单的存储到文件系统。只有当我只放dbstorage,没有其他store语句时,它才会起作用。。

pv_by_industry = GROUP profile_view by viewee_industry_id

pv_avg_by_industry = FOREACH pv_by_industry GENERATE 
    group as viewee_industry_id, AVG(profie_view) AS average_pv;  

STORE pv_avg_by_industry INTO '/tmp/hardik'; 

STORE pv_avg_by_industry into /tmp/hardik/db' INTO 
    DBStorage('com.mysql.jdbc.Driver', 
       'dbc:mysql://hostname/dbname', 'user', 
       'pass', 
       'INSERT INTO table (viewee_industry_id,average_pv) VALUES(?,?)');

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题