Hello, all

Here I have a question about storm doing analytics, I have a data stream coming 
in in real-time, each record associates a timestamp, it supposes to be ingested 
every 1 second from devices, but we know some records are missing, say, 
timestamp1, timestamp2, timestamp5, here timestamp3 and 4 records are missing. 
How can I identify these missing records, what I need to find out what records 
are missed base on the sequential timestamp, and estimate the missing values in 
terms of last record, and next record, i can make the average as this missing 
value. And output of this bolt will be a consecutive of data with no missing 
records.


Thanks


Al

Reply via email to