Just to make sure I'm understanding correctly: Do you have a single stream of sequential ids or multiple streams that need to be interpolated? Do you receive a stream of ids and emit a stream of timestamped ids? On Aug 11, 2015 5:34 PM, "Alec Lee" <[email protected]> wrote:
> 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
