Как передать переменную pig в качестве параметра в операторе LOAD?

Я пытаюсь загрузить данные из Phoenix в сценарий свиньи для обработки

У меня есть сценарий свиньи, как так -

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

Вопрос Как мне передать идентификатор из зерна 1 в сценарий ниже?

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 в качестве параметра для LOAD? Я был в состоянии передать переменные из командной строки, как в моем скрипте, хотя.

0 ответов

Другие вопросы по тегам