如何在load语句中将pig变量作为参数传递?

pqwbnv8z  于 2021-05-29  发布在  Hadoop
关注(0)|答案(0)|浏览(247)

我正在尝试将phoenix的数据加载到pig脚本中进行处理
我有这样一个Pig剧本-

grain1 = LOAD 'cache' USING USING PigStorage(',')
     AS (partitionNumber: chararray, Id: chararray);
DUMP grain1;// grain 1 dumps Id's correctly.

问题:如何将id从grain1传递到下面的脚本中?

outBag = LOAD 'hbase://query/ SELECT MY_COL FROM.MY_TABLE WHERE ID=? AND (SENT_DATE >= to_date(\'$date\', \'$date_format\') - 1) AND (SENT_DATE < to_date(\'$_date\', \'$format\'))'
USING org.apache.phoenix.pig.PhoenixHBaseLoader('localhost')';

如何正确地将上一个pig语句中的值作为要加载的参数传入?不过,我已经能够像在脚本中一样从命令提示符传递变量了。

暂无答案!

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

相关问题