Suspending and resuming continuous queries over data streams

    公开(公告)号:US09910896B2

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

    申请号:US13839148

    申请日:2013-03-15

    IPC分类号: G06F17/30

    摘要: 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.

    METHOD FOR IMPLICIT SESSION ROUTING
    2.
    发明申请
    METHOD FOR IMPLICIT SESSION ROUTING 有权
    隐性会话路由方法

    公开(公告)号:US20150172170A1

    公开(公告)日:2015-06-18

    申请号:US14108994

    申请日:2013-12-17

    IPC分类号: H04L12/733

    摘要: An example method is provided in one example embodiment and includes receiving a packet of a session from a previous hop router at a service zone of a service chain; recording the previous hop router for the session; determining an appliance to service the packet in the service zone using load balancing; recording an appliance identity for servicing the session in the service zone; determining a next hop router in the service chain for the packet using load balancing; and recording the next hop router for the session.

    摘要翻译: 在一个示例实施例中提供了示例性方法,并且包括从服务链的服务区的前一跳路由器接收会话的分组; 记录会话的上一跳路由器; 确定使用负载平衡来服务所述服务区中的分组的设备; 记录在服务区域中为会话服务的设备身份; 使用负载平衡确定所述分组的服务链中的下一跳路由器; 并为会话记录下一跳路由器。

    Method for implicit session routing
    4.
    发明授权
    Method for implicit session routing 有权
    隐式会话路由方法

    公开(公告)号:US09374297B2

    公开(公告)日:2016-06-21

    申请号:US14108994

    申请日:2013-12-17

    摘要: An example method is provided in one example embodiment and includes receiving a packet of a session from a previous hop router at a service zone of a service chain; recording the previous hop router for the session; determining an appliance to service the packet in the service zone using load balancing; recording an appliance identity for servicing the session in the service zone; determining a next hop router in the service chain for the packet using load balancing; and recording the next hop router for the session.

    摘要翻译: 在一个示例实施例中提供了示例性方法,并且包括从服务链的服务区的前一跳路由器接收会话的分组; 记录会话的上一跳路由器; 确定使用负载平衡来服务所述服务区中的分组的设备; 记录在服务区域中为会话服务的设备身份; 使用负载平衡确定所述分组的服务链中的下一跳路由器; 并为会话记录下一跳路由器。

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

    公开(公告)号:US20140280325A1

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

    申请号:US13839148

    申请日:2013-03-15

    IPC分类号: G06F17/30

    摘要: 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.

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