Wso2 Stream Mongo Datetime join query

Question

I try to make a query between a stream (contains a datetime) and a store mongodb table on a datetime column.

define stream TriggerStream (lastexec string);

 @info(name = 'ExtractData')
from TriggerStream as e right outer join OFFRELOG as o
on o.lastmodified> e.lastexec   
select CLIC_OFFRELOG,lastmodified
insert into RECO_TEST;

I get no data from this query. Is there a way to cast datetime column in timsstamp format ?

Best regards, Nicolas

score 0 · Answer 1 · answered Dec 12 '18 at 12:09

The above query works only if the column(lastmodified) is of type long which is matched to a timestamp column of BSON type of long.

Siddhi-store-mongodb does not support date column out of the box. I have opened an issue in the Github repository to track this support.

Wso2 Stream Mongo Datetime join query

1 Answers1