hadoop - 预计 pig 脚本中的QUOTED STRING

Question

我写了一个脚本从vsql中选择:

LOAD 'sql://{select * from sandesh.insights_voice_day
    WHERE Observation_date BETWEEN '2011-11-22' AND '2011-11-23' AND
    Type='total'
    ORDER BY  Observation_date}'

它显示异常为 '' Expecting QUOTEDSTRING?。怎么了

Answer 1

Pig希望在加载后使用带引号的字符串，并带有要加载的文件的名称。 Pig不是SQL，因此您必须执行类似的操作，首先将查询转储到文件中，然后:

A = LOAD "your_file" as (column1:datatype, column2:datatype);
B = FITER A by observation date > '2011-11-22' AND observation_date < '2011-11-23' AND
    Type='total';
C = ORDER B by observation_date;
DUMP C;

现在，这会将它们作为字符串排序。因此，根据所用Pig的版本，您需要使用适当的函数处理时间戳。就像是:

http://pig.apache.org/docs/r0.8.1/api/org/apache/pig/piggybank/evaluation/datetime/convert/CustomFormatToISO.html