I think i got it on my own.   here is the script that i have written   res = FILTER c BY (data::text MATCHES CONCAT(CONCAT('.*',words::word),'.*')); epoch = FOREACH res GENERATE CONCAT(CONCAT(CONCAT(word,'_'),(chararray)ToUnixTime(CurrentTime(created_at))) as epochtime; res1= foreach (group epoch by epochtime){data} dump res1;       ... View more