公开(公告)号：US20140059210A1

公开(公告)日：2014-02-27

申请号：US13594961

申请日：2012-08-27

申请人： Bugra Gedik ,  Gabriela Jacques da Silva ,  Vibhore Kumar ,  Rohit Wagle ,  Kun-Lung Wu

发明人： Bugra Gedik ,  Gabriela Jacques da Silva ,  Vibhore Kumar ,  Rohit Wagle ,  Kun-Lung Wu

IPC分类号： G06F15/173

CPC分类号： G06F9/5066 ,  G06F17/30516 ,  H04L43/08

摘要： Embodiments of the disclosure include a system for providing stream processing with runtime adaptation, having a stream processing application that receives an incoming data stream and a runtime infrastructure configured to execute the stream processing application. The system also includes an orchestrator configured to communicate with the runtime infrastructure and the stream processing application, the orchestrator configured to perform a method. The method includes registering one or more events, wherein each of the events is associated with a stream processing application. The method also includes monitoring, by a processor, for an occurrence of the one or more events associated with the stream processing application, wherein each of the one or more events is associated with one or more runtime metrics. The method further includes receiving an event notification, wherein the event notification includes event identification and an event context and executing an adaptation of the stream processing application.

摘要翻译： 本公开的实施例包括用于提供具有运行时适应的流处理的系统，具有接收输入数据流的流处理应用和被配置为执行流处理应用的运行时基础设施。 该系统还包括经配置以与运行时基础设施和流处理应用程序进行通信的协调者，该协调器被配置为执行方法。 该方法包括登记一个或多个事件，其中每个事件与流处理应用相关联。 该方法还包括由处理器监视与流处理应用相关联的一个或多个事件的发生，其中所述一个或多个事件中的每一个与一个或多个运行时度量相关联。 该方法还包括接收事件通知，其中事件通知包括事件识别和事件上下文以及执行流处理应用的适应。

公开(公告)号：US20110083046A1

公开(公告)日：2011-04-07

申请号：US12575378

申请日：2009-10-07

申请人： HENRIQUE ANDRADE ,  Louis R. Degenaro ,  Bugra Gedik ,  Gabriels Jacques da Silva ,  Vibhore Kumar ,  Kun-Lung Wu

发明人： HENRIQUE ANDRADE ,  Louis R. Degenaro ,  Bugra Gedik ,  Gabriels Jacques da Silva ,  Vibhore Kumar ,  Kun-Lung Wu

IPC分类号： G06F11/30 ,  G06F11/00

CPC分类号： G06F11/0793

摘要： One embodiment of a method for providing failure recovery for an application that processes stream data includes providing a plurality of operators, each of the operators comprising a software element that performs an operation on the stream data, creating one or more groups, each more groups including a subset of the operators, assigning a policy to each of the groups, the policy comprising a definition of how the subset of the operators will function in the event of a failure, and enforcing the policy through one or more control elements that are interconnected with the operators.

摘要翻译： 用于为处理流数据的应用提供故障恢复的方法的一个实施例包括提供多个运营商，每个运营商包括对流数据执行操作的软件元素，创建一个或多个组，每个组包括 运营商的子集，向每个组分配策略，该策略包括关于运营商的子集如何在发生故障的情况下起作用的定义，以及通过一个或多个与 运营商。

公开(公告)号：US20140196017A1

公开(公告)日：2014-07-10

申请号：US13525917

申请日：2012-06-18

申请人： Nagui Halim ,  Vibhore Kumar ,  Kung-Lung Wu ,  Sai Wu

发明人： Nagui Halim ,  Vibhore Kumar ,  Kung-Lung Wu ,  Sai Wu

IPC分类号： G06F9/45

CPC分类号： G06F8/45

摘要： A method of enabling compiler assisted parallelization of one or more stream processing operators in a stream processing application, which consists of a data flow graph with operators as vertices connected by streams. The method includes specifying a parallelized version of one or more of the operators, with a parameterized degree of parallelism, in the stream application, evaluating whether or not to use the parallelized operator, deciding the degree of parallelism of the parallelized operator, if there is a need for a parallelized operator.

摘要翻译： 一种能够在流处理应用中使编译器辅助并行化一个或多个流处理算子的方法，其由作为由流连接的顶点的运算符的数据流图组成。 该方法包括在流应用中指定一个或多个运算符的并行度并行度的并行化版本，评估是否使用并行化运算符，确定并行运算符的并行程度，如果存在 需要并行运算符。

公开(公告)号：US08499292B2

公开(公告)日：2013-07-30

申请号：US12719364

申请日：2010-03-08

申请人： Henrique Andrade ,  Jim Challenger ,  Bugra Gedik ,  Robert Grimm ,  Martin J. Hirzel ,  Vibhore Kumar ,  Robert Soule ,  Kun-Lung Wu

发明人： Henrique Andrade ,  Jim Challenger ,  Bugra Gedik ,  Robert Grimm ,  Martin J. Hirzel ,  Vibhore Kumar ,  Robert Soule ,  Kun-Lung Wu

IPC分类号： G06F9/45

摘要： A virtual execution environment (VEE) for a streaming Intermediate Language (IL), wherein the streaming IL represents a streaming program, communicates streaming data in queues, stores data-at-rest in variables, and determines data by functions, where inputs are read from the queues and the variables, and outputs are written to the queues and the variables.

摘要翻译： 用于流式传输中间语言（IL）的虚拟执行环境（VEE），其中流IL表示流式传输程序，在队列中传送流数据，将静态数据存储在变量中，并通过功能确定数据，其中输入被读取 从队列和变量，并将输出写入队列和变量。

公开(公告)号：US20110219362A1

公开(公告)日：2011-09-08

申请号：US12719364

申请日：2010-03-08

申请人： Henrique Andrade ,  Jim Challenger ,  Bugra Gedik ,  Robert Grimm ,  Martin J. Hirzel ,  Vibhore Kumar ,  Robert Soule ,  Kun-Lung Wu

发明人： Henrique Andrade ,  Jim Challenger ,  Bugra Gedik ,  Robert Grimm ,  Martin J. Hirzel ,  Vibhore Kumar ,  Robert Soule ,  Kun-Lung Wu

IPC分类号： G06F9/45

摘要： A virtual execution environment (VEE) for a streaming Intermediate Language (IL), wherein the streaming IL represents a streaming program, communicates streaming data in queues, stores data-at-rest in variables, and determines data by functions, where inputs are read from the queues and the variables, and outputs are written to the queues and the variables.

摘要翻译： 用于流式传输中间语言（IL）的虚拟执行环境（VEE），其中流IL表示流式传输程序，在队列中传送流数据，将静态数据存储在变量中，并通过功能确定数据，其中输入被读取 从队列和变量，并将输出写入队列和变量。

公开(公告)号：US09063788B2

公开(公告)日：2015-06-23

申请号：US13594961

申请日：2012-08-27

申请人： Bugra Gedik ,  Gabriela Jacques da Silva ,  Vibhore Kumar ,  Rohit Wagle ,  Kun-Lung Wu

发明人： Bugra Gedik ,  Gabriela Jacques da Silva ,  Vibhore Kumar ,  Rohit Wagle ,  Kun-Lung Wu

IPC分类号： G06F15/16 ,  G06F9/50 ,  H04L12/26 ,  G06F17/30

CPC分类号： G06F9/5066 ,  G06F17/30516 ,  H04L43/08

摘要： Embodiments of the disclosure include a system for providing stream processing with runtime adaptation, having a stream processing application that receives an incoming data stream and a runtime infrastructure configured to execute the stream processing application. The system also includes an orchestrator configured to communicate with the runtime infrastructure and the stream processing application, the orchestrator configured to perform a method. The method includes registering one or more events, wherein each of the events is associated with a stream processing application. The method also includes monitoring, by a processor, for an occurrence of the one or more events associated with the stream processing application, wherein each of the one or more events is associated with one or more runtime metrics. The method further includes receiving an event notification, wherein the event notification includes event identification and an event context and executing an adaptation of the stream processing application.

摘要翻译： 本公开的实施例包括用于提供具有运行时适应的流处理的系统，具有接收输入数据流的流处理应用和被配置为执行流处理应用的运行时基础设施。 该系统还包括经配置以与运行时基础设施和流处理应用程序进行通信的协调者，该协调器被配置为执行方法。 该方法包括登记一个或多个事件，其中每个事件与流处理应用相关联。 该方法还包括由处理器监视与流处理应用相关联的一个或多个事件的发生，其中所述一个或多个事件中的每一个与一个或多个运行时度量相关联。 该方法还包括接收事件通知，其中事件通知包括事件识别和事件上下文以及执行流处理应用的适应。

公开(公告)号：US08595732B2

公开(公告)日：2013-11-26

申请号：US12946475

申请日：2010-11-15

申请人： Kirsten W. Hildrum ,  Rohit M. Khandekar ,  Vibhore Kumar ,  Sujay S. Parekh ,  Deepak Rajan ,  Joel L. Wolf ,  Kun-Lung Wu

发明人： Kirsten W. Hildrum ,  Rohit M. Khandekar ,  Vibhore Kumar ,  Sujay S. Parekh ,  Deepak Rajan ,  Joel L. Wolf ,  Kun-Lung Wu

IPC分类号： G06F15/16

CPC分类号： G06F9/4881

摘要： A method for scheduling a data processing job includes receiving the data processing job formed of a plurality of computing units, combining the plurality of computing units into a plurality of sets of tasks, each set including tasks of about equal estimated size, and different sets having different sized tasks, and assigning the tasks to a plurality of processors using a dynamic longest processing time (DLPT) scheme.

摘要翻译： 一种用于调度数据处理作业的方法包括：接收由多个计算单元组成的数据处理作业，将多个计算单元组合成多组任务，每组任务包括约等于估计大小的任务，以及具有 不同大小的任务，以及使用动态最长处理时间（DLPT）方案将任务分配给多个处理器。

公开(公告)号：US08595244B2

公开(公告)日：2013-11-26

申请号：US13285657

申请日：2011-10-31

申请人： Eric Bouillet ,  Vibhore Kumar ,  Laurent Mignet ,  Kuldeep K. Nigam ,  Anand Ranganathan ,  Swati Shah ,  Deepak Turaga

发明人： Eric Bouillet ,  Vibhore Kumar ,  Laurent Mignet ,  Kuldeep K. Nigam ,  Anand Ranganathan ,  Swati Shah ,  Deepak Turaga

IPC分类号： G06F7/00

CPC分类号： G06F17/30961

摘要： A method, system and computer program product for matching an entry of a list to data. The method includes the steps of: generating source code which matches at least a part of said list with said data; compiling said source code into binary code; and determining a match between said list and said data using said compiled binary code wherein at least one of the steps is carried out using a computer device.

摘要翻译： 一种用于将列表的条目与数据进行匹配的方法，系统和计算机程序产品。 该方法包括以下步骤：产生与所述列表的至少一部分匹配的源代码与所述数据; 将所述源代码编译成二进制代码; 以及使用所述编译的二进制码确定所述列表和所述数据之间的匹配，其中使用计算机设备执行至少一个步骤。

公开(公告)号：US20130124668A1

公开(公告)日：2013-05-16

申请号：US13293822

申请日：2011-11-10

申请人： Joseph R. Idziorek ,  Vibhore Kumar ,  Chitra Venkatramani ,  Rohit Wagle

发明人： Joseph R. Idziorek ,  Vibhore Kumar ,  Chitra Venkatramani ,  Rohit Wagle

IPC分类号： G06F15/167

CPC分类号： G06F13/385 ,  H04L47/125

摘要： A method includes receiving, by a computing device, a plurality of data streams from plurality of sources, distributing the data streams to a plurality of sinks on multiple hosts, receiving load information indicating a load on at least one of the plurality of sinks and adjusting the distribution of the data stream accordingly and instructing the plurality of sinks to write the data streams to a distributed data store.

摘要翻译： 一种方法包括：通过计算设备从多个源接收多个数据流，将数据流分配到多个主机上的多个接收器，接收指示多个接收器中的至少一个接收器上的负载的负载信息并调整 相应地分配数据流，并指示多个接收器将数据流写入分布式数据存储。

公开(公告)号：US08903824B2

公开(公告)日：2014-12-02

申请号：US13315415

申请日：2011-12-09

申请人： Leman Akoglu ,  Rohit M. Khandekar ,  Vibhore Kumar ,  Srinivasan Parthasarathy ,  Deepak Rajan ,  Kun-Lung Wu

发明人： Leman Akoglu ,  Rohit M. Khandekar ,  Vibhore Kumar ,  Srinivasan Parthasarathy ,  Deepak Rajan ,  Kun-Lung Wu

IPC分类号： G06F17/30

CPC分类号： G06F17/30327

摘要： A method, an apparatus and an article of manufacture for processing a random-walk based vertex-proximity query on a graph. The method includes computing at least one vertex cluster and corresponding meta-information from a graph, dynamically updating the clustering and corresponding meta-information upon modification of the graph, and identifying a vertex cluster relevant to at least one query vertex and aggregating corresponding meta-information of the cluster to process the query.

摘要翻译： 一种用于在图上处理随机走路的顶点 - 邻近度查询的方法，装置和制品。 该方法包括：从图中计算至少一个顶点簇和对应的元信息，在修改图形时动态地更新聚类和对应的元信息，以及识别与至少一个查询顶点相关的顶点簇， 集群的信息来处理查询。