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(?,?)');
暂无答案!
目前还没有任何答案,快来回答吧!