猪

Question

存储时间我有这样

START_TIME END_TIME 12点十分30秒13点一十分00秒

我想这些信息存储在猪和计算经过时间的数据。 我怎样才能在猪身上做到这一点？ 我只是写了START_TIME-END_TIME但结果却是空白

Answer 1

查询将与此类似：

time = LOAD '/user/name/input_folder/file_name' USING PigStorage() AS (sd:chararray, ed:chararray, t1:chararray, t2:chararray); 
A = FOREACH time GENERATE $0, $1, GetHour(ToDate(t1,'HH:mm:ss')) as hour1, GetHour(ToDate(t2,'HH:mm:ss')) as hour2; 
B = FOREACH A GENERATE ($3 - $2) as time_elapsed; 
dump B;