清管器动态参数

Question

我正在尝试从hbase表中读取值，并将该值作为参数进行十进制

rawConfig = LOAD 'hbase://mytable.config'
      USING org.apache.pig.backend.hadoop.hbase.HBaseStorage(
        'm:config',
        '-gte myTsFlag -lte myTsFlag}'
      ) as (
        tsConfig:chararray
      );

rawCache = FOREACH rawConfig generate (IsEmpty(tsConfig) ? '0':tsConfig) as lastTs;

现在，我希望将rawCache.$0.lastTs的值设置为参数，以便在加载下一个表时使用它

这不起作用

%declare myConfig rawCache.$0.lastTs;
raw = LOAD 'hbase://mytable.users'
      USING org.apache.pig.backend.hadoop.hbase.HBaseStorage(
        'm:1',
        '-minTimestamp $myConfig'
      ) as (email:chararray);

对如何使用上一个表的值有什么想法吗？

我对Pig比较陌生，所以我可能也完全错了:)。

Answer 1

引用语句应该是有效的：

 %declare myConfig 'rawCache.$0.lastTs'