专利快速检索-快速检索全球专利，免费商用专利数据库-IPRDB

31. 发明授权

US08560602B2 Data sharing in a stream processing system 有权
标题翻译：流处理系统中的数据共享
公开(公告)号：US08560602B2
公开(公告)日：2013-10-15
申请号：US13608371
申请日：2012-09-10
申请人： Henrique Andrade , Bugra Gedik , Martin J. Hirzel , Vibhore Kumar , Giuliano Losa , Robert J. Soule , Kun-Lung Wu
发明人： Henrique Andrade , Bugra Gedik , Martin J. Hirzel , Vibhore Kumar , Giuliano Losa , Robert J. Soule , Kun-Lung Wu
IPC分类号： G06F15/16
CPC分类号： G06F9/548 , G06F8/35
摘要： Data sharing is facilitated in stream processing environments, including distributed stream processing environments. A processor of the stream processing environment obtains at least one of usage information for shared data of the stream processing environment, one or more pre-declared characteristics of the shared data, or performance information relating to the stream processing environment. Based on at least one of the usage information, the one or more pre-declared characteristics or the performance information, code is generated for managing the shared data.
摘要翻译：在流处理环境中，包括分布式流处理环境，数据共享便利。流处理环境的处理器获得用于流处理环境的共享数据的使用信息，共享数据的一个或多个预先声明的特性或与流处理环境相关的性能信息中的至少一个。基于使用信息中的至少一个，生成用于管理共享数据的一个或多个预先声明的特征或性能信息的代码。

32. 发明授权

US08407360B2 Generating a distributed stream processing application 有权
标题翻译：生成分布式流处理应用程序
公开(公告)号：US08407360B2
公开(公告)日：2013-03-26
申请号：US13495534
申请日：2012-06-13
申请人： Henrique Andrade , Bugra Gedik , Kun-Lung Wu
发明人： Henrique Andrade , Bugra Gedik , Kun-Lung Wu
IPC分类号： G06F15/16
CPC分类号： G06F9/5066 , G06F17/30516 , G06F17/30545
摘要： Techniques for generating a distributed stream processing application are provided. The techniques include obtaining a declarative description of one or more data stream processing tasks from a graph of operators, wherein the declarative description expresses at least one stream processing task, generating one or more containers that encompass a combination of one or more stream processing operators, and generating one or more execution units from the declarative description of one or more data stream processing tasks, wherein the one or more execution units are deployable across one or more distributed computing nodes, and comprise a distributed data stream processing application binary.
摘要翻译：提供了用于生成分布式流处理应用的技术。这些技术包括从运算符的图形获得一个或多个数据流处理任务的声明性描述，其中所述声明性描述表达至少一个流处理任务，生成包含一个或多个流处理算子的组合的一个或多个容器，以及从一个或多个数据流处理任务的声明性描述生成一个或多个执行单元，其中所述一个或多个执行单元可跨越一个或多个分布式计算节点部署，并且包括分布式数据流处理应用程序二进制。

33. 发明申请

US20130018943A1 DATA SHARING IN A DISTRIBUTED DATA STREAM PROCESSING SYSTEM 有权
标题翻译：分布式数据流处理系统中的数据共享
公开(公告)号：US20130018943A1
公开(公告)日：2013-01-17
申请号：US13608371
申请日：2012-09-10
申请人： Henrique Andrade , Bugra Gedik , Martin J. Hirzel , Vibhore Kumar , Giuliano Losa , Robert J. Soule , Kun-Lung Wu
发明人： Henrique Andrade , Bugra Gedik , Martin J. Hirzel , Vibhore Kumar , Giuliano Losa , Robert J. Soule , Kun-Lung Wu
IPC分类号： G06F15/177
CPC分类号： G06F9/548 , G06F8/35
摘要： State sharing is facilitated in stream processing environments, including distributed stream processing environments. A customized shared state implementation representing the state to be shared is automatically created based on at least one of user preferences, hints of usage, and system performance.
摘要翻译：在流处理环境（包括分布式流处理环境）中便利了状态共享。基于用户偏好，使用提示和系统性能中的至少一个，自动创建表示要共享的状态的定制共享状态实现。

34. 发明申请

US20120259910A1 Generating a Distributed Stream Processing Application 有权
标题翻译：生成分布式流处理应用程序
公开(公告)号：US20120259910A1
公开(公告)日：2012-10-11
申请号：US13495534
申请日：2012-06-13
申请人： Henrique Andrade , Bugra Gedik , Kun-Lung Wu
发明人： Henrique Andrade , Bugra Gedik , Kun-Lung Wu
IPC分类号： G06F15/16 , G06F9/45
CPC分类号： G06F9/5066 , G06F17/30516 , G06F17/30545
摘要： Techniques for generating a distributed stream processing application are provided. The techniques include obtaining a declarative description of one or more data stream processing tasks from a graph of operators, wherein the declarative description expresses at least one stream processing task, generating one or more containers that encompass a combination of one or more stream processing operators, and generating one or more execution units from the declarative description of one or more data stream processing tasks, wherein the one or more execution units are deployable across one or more distributed computing nodes, and comprise a distributed data stream processing application binary.
摘要翻译：提供了用于生成分布式流处理应用的技术。这些技术包括从运算符的图形获得一个或多个数据流处理任务的声明性描述，其中所述声明性描述表达至少一个流处理任务，生成包含一个或多个流处理算子的组合的一个或多个容器，以及从一个或多个数据流处理任务的声明性描述生成一个或多个执行单元，其中所述一个或多个执行单元可跨越一个或多个分布式计算节点部署，并且包括分布式数据流处理应用程序二进制。

35. 发明授权

US08285780B2 State sharing in a distributed data stream processing system 失效
标题翻译：分布式数据流处理系统中的状态共享
公开(公告)号：US08285780B2
公开(公告)日：2012-10-09
申请号：US12791484
申请日：2010-06-01
申请人： Henrique Andrade , Bugra Gedik , Martin J. Hirzel , Vibhore Kumar , Giuliano Losa , Robert J. Soule , Kun-Lung Wu
发明人： Henrique Andrade , Bugra Gedik , Martin J. Hirzel , Vibhore Kumar , Giuliano Losa , Robert J. Soule , Kun-Lung Wu
IPC分类号： G06F15/16
CPC分类号： G06F9/548 , G06F8/35
摘要： State sharing is facilitated in stream processing environments, including distributed stream processing environments. A customized shared state implementation representing the state to be shared is automatically created based on at least one of user preferences, hints of usage, and system performance.
摘要翻译：在流处理环境（包括分布式流处理环境）中便利了状态共享。基于用户偏好，使用提示和系统性能中的至少一个，自动创建表示要共享的状态的定制共享状态实现。

36. 发明申请

US20110295939A1 STATE SHARING IN A DISTRIBUTED DATA STREAM PROCESSING SYSTEM 失效
标题翻译：分布式数据流处理系统中的状态共享
公开(公告)号：US20110295939A1
公开(公告)日：2011-12-01
申请号：US12791484
申请日：2010-06-01
申请人： Henrique Andrade , Bugra Gedik , Martin J. Hirzel , Vibhore Kumar , Giuliano Losa , Robert J. Soule , Kun-Lung Wu
发明人： Henrique Andrade , Bugra Gedik , Martin J. Hirzel , Vibhore Kumar , Giuliano Losa , Robert J. Soule , Kun-Lung Wu
IPC分类号： G06F15/16 , G06F15/177
CPC分类号： G06F9/548 , G06F8/35
摘要： State sharing is facilitated in stream processing environments, including distributed stream processing environments. A customized shared state implementation representing the state to be shared is automatically created based on at least one of user preferences, hints of usage, and system performance.
摘要翻译：在流处理环境（包括分布式流处理环境）中便利了状态共享。基于用户偏好，使用提示和系统性能中的至少一个，自动创建表示要共享的状态的定制共享状态实现。

37. 发明申请

US20110225584A1 MANAGING MODEL BUILDING COMPONENTS OF DATA ANALYSIS APPLICATIONS 失效
标题翻译：管理数据分析应用的建模组件
公开(公告)号：US20110225584A1
公开(公告)日：2011-09-15
申请号：US12721649
申请日：2010-03-11
申请人： Henrique Andrade , Bugra Gedik , Vibhore Kumar , Kun-Lung Wu
发明人： Henrique Andrade , Bugra Gedik , Vibhore Kumar , Kun-Lung Wu
IPC分类号： G06F9/50
CPC分类号： G06F9/50 , G06F11/3447
摘要： Data analysis applications include model building components and stream processing components. To increase utility of the data analysis application, in one embodiment, the model building component of the data analysis application is managed. Management includes resource allocation and/or configuration adaptation of the model building component, as examples.
摘要翻译：数据分析应用程序包括模型构建组件和流处理组件。为了增加数据分析应用的实用性，在一个实施例中，管理数据分析应用的模型构建组件。例如，管理包括模型构建组件的资源分配和/或配置适配。

38. 发明申请

US20110061060A1 Determining Operator Partitioning Constraint Feasibility 有权
标题翻译：确定操作员分区约束可行性
公开(公告)号：US20110061060A1
公开(公告)日：2011-03-10
申请号：US12556931
申请日：2009-09-10
申请人： Henrique Andrade , Bugra Gedik , Kirsten W. Hildrum , Rohit M. Khandekar , Sujay S. Parekh , Deepak Rajan , Joel L. Wolf , Kun-Lung Wu
发明人： Henrique Andrade , Bugra Gedik , Kirsten W. Hildrum , Rohit M. Khandekar , Sujay S. Parekh , Deepak Rajan , Joel L. Wolf , Kun-Lung Wu
IPC分类号： G06F9/46
CPC分类号： G06F9/5066
摘要： Techniques for determining feasibility of a set of one or more operator partitioning constraints are provided. The techniques include receiving one or more sets of operator partitioning constraints, wherein each set of one or more constraints define one or more desired conditions for grouping together of operators into partitions and placing partitions on hosts, wherein each operator is embodied as software that performs a particular function, processing each set of one or more operator partitioning constraints to determine feasibility of each set of one or more operator partitioning constraints, creating and outputting one or more candidate partitions and one or more host placements for each set of feasible partitioning constraints, and creating and outputting a certificate of infeasibility for each set of infeasible partitioning constraints, wherein the certificate of infeasibility outlines one or more reasons for infeasibility.
摘要翻译：提供了用于确定一组或多个操作者分区约束的可行性的技术。这些技术包括接收一组或多组运算符分配约束，其中每组一个或多个约束定义一个或多个期望条件，用于将运算符分组到分区中并在主机上放置分区，其中每个运算符被实现为执行特定功能，处理每组一个或多个运营商划分约束以确定每组一个或多个运营商分区约束的可行性，为每组可行分区约束创建和输出一个或多个候选分区和一个或多个主机布局，以及创建和输出每组不可行分区约束的不可行性证书，其中，不可行性证书概述了一个或多个不可行性的原因。

39. 发明申请

US20100325621A1 PARTITIONING OPERATOR FLOW GRAPHS 有权
标题翻译：分区操作员流程图
公开(公告)号：US20100325621A1
公开(公告)日：2010-12-23
申请号：US12489805
申请日：2009-06-23
申请人： Henrique Andrade , Bugra Gedik , Kirsten W. Hildrum , Rohit M. Khandekar , Sunjay S. Parekh , Deepak Rajan , Joel L. Wolf , Kun-Lung Wu
发明人： Henrique Andrade , Bugra Gedik , Kirsten W. Hildrum , Rohit M. Khandekar , Sunjay S. Parekh , Deepak Rajan , Joel L. Wolf , Kun-Lung Wu
IPC分类号： G06F9/45
CPC分类号： G06F8/443 , G06F8/433 , G06F8/44
摘要： Techniques for partitioning an operator flow graph are provided. The techniques include receiving source code for a steam processing application, wherein the source code comprises an operator flow graph, wherein the operator flow graph comprises a plurality of operators, receiving profiling data associated with the plurality of operators and one or more processing requirements of the operators, defining a candidate partition as a coalescing of one or more of the operators into one or more sets of processing elements (PEs), using the profiling data to create one or more candidate partitions of the processing elements, using the one or more candidate partitions to choose a desired partitioning of the operator flow graph, and compiling the source code into an executable code based on the desired partitioning.
摘要翻译：提供了划分操作员流程图的技术。这些技术包括接收蒸汽处理应用的源代码，其中源代码包括操作者流程图，其中操作者流程图包括多个操作者，接收与多个操作者相关联的分析数据和一个或多个处理要求运营商，使用所述分析数据，使用所述一个或多个候选者来创建一个或多个所述处理元件的候选分区，将候选分区定义为将一个或多个运算符合并为一组或多组处理元素（PE）分区以选择操作员流图的期望分区，并且基于期望的分区将源代码编译成可执行代码。

40. 发明申请

US20100293283A1 ON-DEMAND MARSHALLING AND DE-MARSHALLING OF NETWORK MESSAGES 审中-公开
标题翻译：网络消息的需求和MAR MARTING
公开(公告)号：US20100293283A1
公开(公告)日：2010-11-18
申请号：US12464599
申请日：2009-05-12
申请人： HENRIQUE ANDRADE , Bugra Gedik , Kun-Lung Wu
发明人： HENRIQUE ANDRADE , Bugra Gedik , Kun-Lung Wu
IPC分类号： G06F15/16
CPC分类号： G06F9/547
摘要： One embodiment of a method for on-demand de-marshalling of a network message includes receiving a first network message at a receiver device, wherein the first network message was sent from a sender device, and wherein the first network message comprises one or more attributes that characterize an object at the sender device, and further wherein the first network message is in an encoded format according to a network protocol, storing the first network message in a buffer of the receiver device in the encoded format, identifying, at the receiver device and prior to de-marshalling of any of the attributes, that at least one of the attributes is to be manipulated by the receiver device, de-marshalling, in response to the identifying, the identified attribute(s), and manipulating the identified attribute(s) at the receiver device.
摘要翻译：用于网络消息的按需解组合的方法的一个实施例包括在接收机设备处接收第一网络消息，其中从发送方设备发送第一网络消息，并且其中第一网络消息包括一个或多个属性其特征在于在所述发送方设备处的对象，并且其中所述第一网络消息是根据网络协议的编码格式，以所述编码格式将所述第一网络消息存储在所述接收机设备的缓冲器中，以在所述接收机设备并且在对任何属性进行解组之前，至少一个属性将由接收机设备操纵，响应于识别所识别的属性而解组，并操纵所识别的属性（s）在接收机设备。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式