SUSPENDING AND RESUMING CONTINUOUS QUERIES OVER DATA STREAMS
    1.
    发明申请
    SUSPENDING AND RESUMING CONTINUOUS QUERIES OVER DATA STREAMS 有权
    数据流中的连续和重复连续查询

    公开(公告)号:US20140280325A1

    公开(公告)日:2014-09-18

    申请号:US13839148

    申请日:2013-03-15

    CPC classification number: G06F17/30516 G06F17/30492 G06F17/30545

    Abstract: In an embodiment, a method comprises processing an input data stream as the data stream is streamed and producing a derived stream therefrom; storing the input data stream in an input archive; suspending processing of the input data stream; subsequent to suspending processing, resuming processing of the input data stream, wherein resuming comprises: storing newly received data in the input data stream in a buffer, as the input data stream is streamed; determining a first timestamp; determining a second timestamp; searching the input archive to find a data item that matches the first timestamp of the last processed data item; processing data in the input archive having timestamps that are greater than the first timestamp until arriving at data with a third timestamp that is greater than the second timestamp; processing the input data stream from the buffer; continuing processing the input data stream as the input stream is streamed.

    Abstract translation: 在一个实施例中,一种方法包括在数据流被流式传输时处理输入数据流,并从中产生派生的流; 将输入数据流存储在输入存档中; 暂停输入数据流的处理; 在暂停处理之后,恢复输入数据流的处理,其中恢复包括:当输入数据流被流传输时,将输入数据流中的新接收的数据存储在缓冲器中; 确定第一时间戳; 确定第二时间戳; 搜索输入存档以找到与最后处理的数据项的第一个时间戳相匹配的数据项; 处理输入存档中的数据,其具有大于第一时间戳的时间戳,直到达到具有大于第二时间戳的第三时间戳的数据; 从缓冲器处理输入数据流; 在输入流被流传输时继续处理输入数据流。

    Suspending and resuming continuous queries over data streams

    公开(公告)号:US09910896B2

    公开(公告)日:2018-03-06

    申请号:US13839148

    申请日:2013-03-15

    CPC classification number: G06F17/30516 G06F17/30492 G06F17/30545

    Abstract: In an embodiment, a method comprises processing an input data stream as the data stream is streamed and producing a derived stream therefrom; storing the input data stream in an input archive; suspending processing of the input data stream; subsequent to suspending processing, resuming processing of the input data stream, wherein resuming comprises: storing newly received data in the input data stream in a buffer, as the input data stream is streamed; determining a first timestamp; determining a second timestamp; searching the input archive to find a data item that matches the first timestamp of the last processed data item; processing data in the input archive having timestamps that are greater than the first timestamp until arriving at data with a third timestamp that is greater than the second timestamp; processing the input data stream from the buffer; continuing processing the input data stream as the input stream is streamed.

Patent Agency Ranking