-
公开(公告)号：EP3365781B1
公开(公告)日：2020-09-16
申请号：EP16794796.9
申请日：2016-10-20
IPC分类号： G06F16/2455 , G06F16/9535 , G06F9/54
-
2.发明公开
公开(公告)号：EP3365785A1
公开(公告)日：2018-08-29
申请号：EP16730951.7
申请日：2016-06-03
IPC分类号： G06F11/14
CPC分类号： G06F11/1471 , G06F9/542 , G06F11/1438 , G06F17/30088 , G06F17/30404 , G06F2201/805 , G06F2201/84
摘要： An event processing system is disclosed that processes events of an event stream, performs the recovery of events during system failure and preserves the state of the system reliably and accurately while achieving desired system performance. In an embodiment, the event processing system processes a first batch of events of a continuous input stream of events using a continuous query and generates an output stream of events related to an application. The event processing system identifies one or more operators of the continuous query and determines that an operator is a journaled operator. The event processing system generates a journaled snapshot of a current state of the system based on execution of the journaled operator on at least the first batch of events and stores the journaled snapshot of the current state of the system.
-
3.发明公开
公开(公告)号：EP3198479A1
公开(公告)日：2017-08-02
申请号：EP15778105.5
申请日：2015-09-21
发明人： DE CASTRO ALVES, Alexandre , DESHMUKH, Unmesh Anil , BEDEKAR, Yogesh , THUKKARAM, Prabhu , MAHENDRU, Ashish
IPC分类号： G06F17/30
CPC分类号： G06F17/30516 , G06F17/30339 , G06F17/30557 , G06F17/30867
摘要： Some event ordering requirements can be determined based on continuous event processing queries. Other event ordering requirements can be determined based on distribution flow types being used to distribute events from event streams to node executing the queries. Events from event streams can be ordered according to ordering semantics that are based on a combination of all of these event ordering requirements. Additionally, virtual computing nodes can be associated with constraints, and computing processors can be associated with capabilities. Virtual computing nodes for processing event streams can be assigned to execute on various computing processors based on both these constraints and capabilities. Additionally, for each of several events in an event stream, a ratio between a total latency and a communication latency can be for determined. Based on an average of these ratios, a quantity of reducing nodes that will be involved in a map-reduce operation can be selected.
摘要翻译： 一些事件排序要求可以基于连续的事件处理查询来确定。 其他事件排序要求可以基于用于将事件从事件流分发到执行查询的节点的分发流类型来确定。 来自事件流的事件可以根据基于所有这些事件排序要求的组合的排序语义进行排序。 另外，虚拟计算节点可以与约束相关联，并且计算处理器可以与能力相关联。 用于处理事件流的虚拟计算节点可以被分配以基于这些约束和能力在各种计算处理器上执行。 另外，对于事件流中的多个事件中的每一个事件，可以确定总等待时间和通信等待时间之间的比率。 基于这些比率的平均值，可以选择将涉及地图缩小操作的减少节点的数量。
-
公开(公告)号：EP3005164A1
公开(公告)日：2016-04-13
申请号：EP14733856.0
申请日：2014-05-28
IPC分类号： G06F17/30
CPC分类号： G06F17/30516
摘要： Techniques for managing value-based windows on relations are provided. In some examples, an input relation is generated. The input relation is a bounded set of data records related to an application. A continuous query that identifies the input relation may be received. Additionally, a configurable window operator associated with processing the input relation may be identified. Then, the continuous query may be executed based at least in part on the configurable window operator to generate an output relation. Further, in some instances, the data records of the output relation may be provided based at least in part on execution of the continuous query.
-
5.发明公开
公开(公告)号：EP3910476A1
公开(公告)日：2021-11-17
申请号：EP21181427.2
申请日：2016-06-03
IPC分类号： G06F11/14
摘要： This disclosure relates to a system comprising: a memory storing a plurality of instructions; and one or more processors configured to access the memory and execute the plurality of instructions to at least: receive a continuous input stream of events related to an application; determine an interval for inserting a checkpoint marker event into the stream of events, wherein the size of the interval is determined based at least in part on a type of the application, a latency requirement of the application, and a frequency at which events of the input stream of events are received; process the continuous input stream of events to generate an output stream of events related to the application, the processing comprising inserting the checkpoint marker event into the continuous input stream to create an event batch, and the event batch including each event of the continuous input stream of events received during the determined interval; determine an output sequence number for an output event in the output stream of events; transmit the output event in the output stream of events; store the output sequence number of the output event; while the continuous input stream of events is being processed, receive an indication of failure of the system; determine a current output sequence number of a most recently transmitted output event in the output stream of events; determine a most recently processed event batch; in response to the indication of failure of the system, re-process the events in the most recently processed event batch and determine a set of one or more output events of the output stream to be transmitted based on the current output sequence number and the most recently processed event batch, the set of one or more output events to be transmitted comprising each of the re-processed events having an output sequence number greater than the output sequence number of the most recently processed event; and transmit the set of one or more output events related to the application.
-
公开(公告)号：EP3365781A1
公开(公告)日：2018-08-29
申请号：EP16794796.9
申请日：2016-10-20
摘要： Systems and methods for guaranteeing the event order for multi-stage processing in distributed systems are disclosed. In some examples, a warm-up period is used to accurately determine a starting point for ordered events of an event stream. Skip-beats may be utilized as dummy events so that the event processor does not wait too long for events that were filtered out at earlier stages.
-
公开(公告)号：EP2946314A1
公开(公告)日：2015-11-25
申请号：EP14704710.4
申请日：2014-01-09
IPC分类号： G06F17/30
CPC分类号： G06F17/30864 , G06F17/30286
摘要： Techniques for performing non-event pattern matching on continuous event streams using variable duration. The duration value used in non-event pattern matching can be variable. Accordingly, a first pattern match candidate can have a different associated duration from a second pattern match candidate for matches arising from events received via an event stream. In certain embodiments, the duration for a candidate pattern match may be based upon one or more attributes of an event that started the candidate pattern match or based upon an expression (e.g., an arithmetic expression) involving one or more attributes of the event.
-
-
-
-
-
-
搜索结果
7 条记录 (耗时 0.016 秒)
