-
公开(公告)号:US20160103882A1
公开(公告)日:2016-04-14
申请号:US14973377
申请日:2015-12-17
IPC分类号: G06F17/30
CPC分类号: G06F17/30516 , B29D30/0681 , B29D2030/0682 , B32B27/08 , B32B27/34 , B60C1/0008 , B60C5/14 , G06F17/30389 , G06F17/30424 , G06F17/30442 , G06F17/30451 , G06F17/30457 , G06F17/30477 , G06F17/30483 , G06F17/30498 , G06F17/30548 , G06F17/30551 , G06F17/30554 , G06F17/30557 , G06F17/30616 , G06F17/30864 , G06F17/30958
摘要: Techniques for managing configurable data windows for streams and/or archived relations are provided. In some examples, a query that identifies at least a data stream or an archived relation may be identified. Additionally, a configurable window size may be identified. In some instances, the query may be initialized with at least a portion of the historical data based at least in part on the window size. Further, the query may be evaluated based at least in part on the data stream and the portion of the historical data.
摘要翻译: 提供了用于管理用于流和/或存档关系的可配置数据窗口的技术。 在一些示例中,可以识别至少识别数据流或归档关系的查询。 另外,可以识别可配置的窗口大小。 在一些情况下,至少部分地基于窗口大小,可以利用历史数据的至少一部分来初始化查询。 此外,可以至少部分地基于数据流和历史数据的部分来评估查询。
-
公开(公告)号:US09286352B2
公开(公告)日:2016-03-15
申请号:US13828640
申请日:2013-03-14
发明人: Hoyong Park , Anand Srinivasan , Vikram Shukla
CPC分类号: G06F17/30516 , B29D30/0681 , B29D2030/0682 , B32B27/08 , B32B27/34 , B60C1/0008 , B60C5/14 , G06F17/30389 , G06F17/30424 , G06F17/30442 , G06F17/30451 , G06F17/30457 , G06F17/30477 , G06F17/30483 , G06F17/30498 , G06F17/30548 , G06F17/30551 , G06F17/30554 , G06F17/30557 , G06F17/30616 , G06F17/30864 , G06F17/30958
摘要: Techniques for implementing the hybrid execution of continuous and scheduled queries are provided. In some examples, a query engine may be initialized with relational data from at least a first source. For example, the first source may include a database or other system that can provide historical data. Additionally, the query engine may be enabled to provide query results based at least in part on the relational data from at least the first source and streaming data from at least a second source. In some examples, the second source may be a data stream.
摘要翻译: 提供了实现连续和预定查询的混合执行的技术。 在一些示例中,可以使用来自至少第一源的关系数据来初始化查询引擎。 例如,第一源可以包括可以提供历史数据的数据库或其他系统。 另外,可以使查询引擎能够至少部分地基于来自至少第一源的关系数据和来自至少第二源的流数据来提供查询结果。 在一些示例中,第二源可以是数据流。
-
公开(公告)号:US09262258B2
公开(公告)日:2016-02-16
申请号:US14692674
申请日:2015-04-21
CPC分类号: G06F11/0793 , G06F11/0709 , G06F11/0727 , G06F11/202 , G06F17/30516 , G06F17/30864
摘要: The concept of faults and fault handling are added to the execution of continuous event processing (CEP) queries. By introducing fault handling techniques to the processing of CEP queries, users are enabled to instruct a CEP query processor to respond to faults in a customized manner that does not necessarily involve the halting of the CEP query relative to which the faults occurred. For example, a fault might be due to a temporary problem. Under such circumstances, the CEP query processor can be instructed to ignore the fault and allow the execution of the CEP query to continue relative to the remainder of the event stream. Alternatively, if the fault is due to a problem with the CEP query itself, then the CEP query processor can be instructed to propagate the fault through the query processing system until the fault ultimately causes the problematic CEP query to be halted.
-
24.
公开(公告)号:US09110945B2
公开(公告)日:2015-08-18
申请号:US14077230
申请日:2013-11-12
IPC分类号: G06F17/30
CPC分类号: G06F17/30433 , G06F17/30427 , G06F17/30448
摘要: The present invention includes a method for providing parameterized queries in complex event processing (CEP). The method includes providing a query template which includes one or more bind variables, providing sets of parameters corresponding to the one or more bind variables, and parsing the query template to determine positions of the one or more bind variables. The method further includes scanning the provided sets of parameters to determine which of the sets of parameters are to be bound to the one or more bind variables, binding the one or more bind variables which are determined to be bound to the sets of parameters, and substituting the bound one or more bind variables with the corresponding sets of parameters. The method further includes injecting all incarnations of the parameterized queries into the system, and one template/parameterized query is configured to run them all.
摘要翻译: 本发明包括一种在复杂事件处理(CEP)中提供参数化查询的方法。 该方法包括提供包括一个或多个绑定变量的查询模板,提供与一个或多个绑定变量相对应的参数集合,以及解析查询模板以确定一个或多个绑定变量的位置。 该方法还包括扫描所提供的参数集合以确定参数组中的哪一组要绑定到一个或多个绑定变量,将被确定为绑定的一个或多个绑定变量绑定到参数集合,以及 用绑定的一个或多个绑定变量替换相应的参数集。 该方法还包括将参数化查询的所有形式注入到系统中,并且一个模板/参数化查询被配置为全部运行它们。
-
公开(公告)号:US20150227415A1
公开(公告)日:2015-08-13
申请号:US14692674
申请日:2015-04-21
CPC分类号: G06F11/0793 , G06F11/0709 , G06F11/0727 , G06F11/202 , G06F17/30516 , G06F17/30864
摘要: The concept of faults and fault handling are added to the execution of continuous event processing (CEP) queries. By introducing fault handling techniques to the processing of CEP queries, users are enabled to instruct a CEP query processor to respond to faults in a customized manner that does not necessarily involve the halting of the CEP query relative to which the faults occurred. For example, a fault might be due to a temporary problem. Under such circumstances, the CEP query processor can be instructed to ignore the fault and allow the execution of the CEP query to continue relative to the remainder of the event stream. Alternatively, if the fault is due to a problem with the CEP query itself, then the CEP query processor can be instructed to propagate the fault through the query processing system until the fault ultimately causes the problematic CEP query to be halted.
摘要翻译: 故障和故障处理的概念被添加到执行连续事件处理(CEP)查询。 通过将故障处理技术引入到CEP查询的处理中,用户能够指示CEP查询处理器以定制的方式响应故障,这些定制方式不一定涉及停止发生故障的CEP查询。 例如,故障可能是由于临时问题。 在这种情况下,可以指示CEP查询处理器忽略故障,并允许CEP查询的执行相对于事件流的其余部分继续执行。 或者,如果故障是由于CEP查询本身的问题,则可以指示CEP查询处理器通过查询处理系统传播故障,直到故障最终导致有问题的CEP查询被停止。
-
公开(公告)号:US09098587B2
公开(公告)日:2015-08-04
申请号:US13839288
申请日:2013-03-15
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.
摘要翻译: 使用可变持续时间在连续事件流上执行非事件模式匹配的技术。 在非事件模式匹配中使用的持续时间值可以是变量。 因此,第一模式匹配候选可以具有与从经由事件流接收的事件产生的匹配的第二模式匹配候选的不同的关联持续时间。 在某些实施例中,候选模式匹配的持续时间可以基于启动候选模式匹配的事件的一个或多个属性,或者基于涉及事件的一个或多个属性的表达式(例如,算术表达式)。
-
公开(公告)号:US20150161214A1
公开(公告)日:2015-06-11
申请号:US14559550
申请日:2014-12-03
发明人: Prathab Kali , Anand Srinivasan , Sandeep Bishnoi
IPC分类号: G06F17/30
CPC分类号: G06F17/30495 , G06F17/30516
摘要: A method for detecting patterns across multiple input data streams related to one or more applications is disclosed. The method includes receiving multiple input data streams and generating one or more dynamic data types for one or more attributes of the input data streams. In some embodiments, the method may include combining the input data streams to generate a combined input data stream based on the dynamic data types and processing a continuous query over the combined data stream to detect a pattern.
摘要翻译: 公开了一种用于检测与一个或多个应用相关的多个输入数据流的模式的方法。 该方法包括接收多个输入数据流并为输入数据流的一个或多个属性生成一个或多个动态数据类型。 在一些实施例中,该方法可以包括组合输入数据流以基于动态数据类型生成组合输入数据流,并通过组合数据流处理连续查询以检测模式。
-
公开(公告)号:US09047249B2
公开(公告)日:2015-06-02
申请号:US13770969
申请日:2013-02-19
CPC分类号: G06F11/0793 , G06F11/0709 , G06F11/0727 , G06F11/202 , G06F17/30516 , G06F17/30864
摘要: The concept of faults and fault handling are added to the execution of continuous event processing (CEP) queries. By introducing fault handling techniques to the processing of CEP queries, users are enabled to instruct a CEP query processor to respond to faults in a customized manner that does not necessarily involve the halting of the CEP query relative to which the faults occurred. For example, a fault might be due to a temporary problem. Under such circumstances, the CEP query processor can be instructed to ignore the fault and allow the execution of the CEP query to continue relative to the remainder of the event stream. Alternatively, if the fault is due to a problem with the CEP query itself, then the CEP query processor can be instructed to propagate the fault through the query processing system until the fault ultimately causes the problematic CEP query to be halted.
摘要翻译: 故障和故障处理的概念被添加到执行连续事件处理(CEP)查询。 通过将故障处理技术引入到CEP查询的处理中,用户能够指示CEP查询处理器以定制的方式响应故障,这些定制方式不一定涉及停止发生故障的CEP查询。 例如,故障可能是由于临时问题。 在这种情况下,可以指示CEP查询处理器忽略故障,并允许CEP查询的执行相对于事件流的其余部分继续执行。 或者,如果故障是由于CEP查询本身的问题,则可以指示CEP查询处理器通过查询处理系统传播故障,直到故障最终导致有问题的CEP查询被停止。
-
公开(公告)号:US20140201355A1
公开(公告)日:2014-07-17
申请号:US13838259
申请日:2013-03-15
发明人: Sandeep Bishnoi , Anand Srinivasan
IPC分类号: H04L12/26
CPC分类号: H04L41/069 , H04L41/0622 , H04L41/0686
摘要: Improved techniques are provided for processing streams of data. The duration of the time that an event is eligible for remaining in a time-based window can be variable for different events received via the same event stream. In certain embodiments, the duration of time that an input event spends in a time-based window is a function of one or more values of one or more attributes of the event. Since different events can have different one or more attribute values, the different events can spend different amounts of time in the time-based window for that event stream. The amount of time that an event spends in a time-based window can be controlled via the one or more attributes of the event.
摘要翻译: 提供了改进的技术来处理数据流。 事件有资格保留在时间窗口中的持续时间可以通过相同的事件流接收的不同事件是可变的。 在某些实施例中,输入事件在基于时间的窗口中花费的持续时间是事件的一个或多个属性的一个或多个值的函数。 由于不同的事件可以具有不同的一个或多个属性值,所以不同的事件可以在该事件流的基于时间的窗口中花费不同的时间量。 事件在时间窗口中花费的时间量可以通过事件的一个或多个属性进行控制。
-
公开(公告)号:US20140095537A1
公开(公告)日:2014-04-03
申请号:US13830378
申请日:2013-03-14
发明人: Hoyong Park , Anand Srinivasan , Roger Bolsius , Eric Hsiao , Jeffrey Toillion , Vikram Shukla
IPC分类号: G06F17/30
CPC分类号: B60C1/0008 , B29D30/0681 , B29D2030/0682 , B32B27/08 , B32B27/34 , B60C5/14 , G06F16/242 , G06F16/245 , G06F16/2453 , G06F16/24535 , G06F16/24539 , G06F16/2455 , G06F16/24553 , G06F16/2456 , G06F16/24568 , G06F16/2474 , G06F16/2477 , G06F16/248 , G06F16/25 , G06F16/313 , G06F16/9024 , G06F16/951
摘要: Techniques for managing real-time business event analysis and monitoring are provided. In some examples, a logical request may be received at a business intelligence server configured with a continuous query service. Additionally, the continuous query service may be configured to translate the logical request into a physical request. Further, business intelligence information may be provided based at least in part on querying against an event data stream with a continuous query configured based at least in part on the physical request translated by the continuous query service.
摘要翻译: 提供了管理实时业务事件分析和监控的技术。 在一些示例中,可以在配置有连续查询服务的商业智能服务器处接收逻辑请求。 另外,连续查询服务可以被配置为将逻辑请求转换成物理请求。 此外,可以至少部分地基于至少部分地基于由连续查询服务翻译的物理请求而配置的连续查询来针对事件数据流的查询来提供商业智能信息。
-
-
-
-
-
-
-
-
-