公开(公告)号：US07818313B1

公开(公告)日：2010-10-19

申请号：US11486902

申请日：2006-07-14

申请人： Mark Tsimelzon ,  Aleksey Sanin ,  Robert B. Hagmann

发明人： Mark Tsimelzon ,  Aleksey Sanin ,  Robert B. Hagmann

IPC分类号： G06F7/00 ,  G06F17/30

CPC分类号： G06F17/30545 ,  Y10S707/966

摘要： A method, in a continuous computation system, for processing a set of registered queries over a cluster of servers includes creating an execution plan for processing a set of queries over a cluster of servers, where the continuous computation system creates the execution plan by analyzing the semantics and requirements of the queries to determine how to distribute processing across the cluster. Analysis of a query can include determining whether input messages for the query can be processed independent of each other, whether input messages for the query can be partitioned into groups that can be processed independent of each other, whether the query includes an aggregator function, and whether the query includes a subquery.

摘要翻译： 在连续计算系统中，用于在服务器集群上处理一组注册查询的方法包括创建用于在服务器集群上处理一组查询的执行计划，其中连续计算系统通过分析 查询的语义和要求，以确定如何在集群中分发处理。 查询的分析可以包括确定用于查询的输入消息是否可以彼此独立地被处理，查询的输入消息是否可被划分成可以被彼此独立地处理的组，查询是否包括聚合器功能，以及 查询是否包含子查询。

公开(公告)号：US08046744B1

公开(公告)日：2011-10-25

申请号：US12148903

申请日：2008-04-23

申请人： Ian D. Marshall ,  Aleksey Sanin ,  Mark Tsimelzon ,  Robert B. Hagmann

发明人： Ian D. Marshall ,  Aleksey Sanin ,  Mark Tsimelzon ,  Robert B. Hagmann

IPC分类号： G06F9/44

CPC分类号： G06F11/3419

摘要： The present invention provides a system and method for measuring latency in a continuous processing system. The invention involves generating “tracer” messages that are specifically designed for measuring latency. A tracer message is configured to pass through and be outputted by each primitive in the tracer message's path regardless of the function of the primitive and without changing the state of the primitive. Tracer messages are not filtered by filter primitives or delayed by time-delay primitives. Tracer messages are detected and discarded within loops. These rules provide for predictable behavior of tracer messages, thereby making them reliable indicators of latency and liveness in the continuous processing system. A tracer message is inserted into the continuous processing system at a desired start point for measuring latency. At a desired end point for measuring latency, latency is measured by calculating the amount of time the tracer message took to travel from the start point to the end point.

摘要翻译： 本发明提供了一种用于在连续处理系统中测量等待时间的系统和方法。 本发明涉及产生专门用于测量延迟的“跟踪器”消息。 跟踪消息被配置为在跟踪消息的路径中的每个基元通过并输出，而不管原语的功能如何，而不改变原语的状态。 跟踪消息不被过滤器原语过滤，也不会被延时原语延迟。 跟踪消息在循环内被检测和丢弃。 这些规则提供了示踪消息的可预测行为，从而使其成为连续处理系统中可靠的延迟和活动指标。 在期望的开始点将跟踪消息插入到连续处理系统中以测量等待时间。 在用于测量延迟的期望终点，通过计算示踪消息从起点到终点行进的时间量来测量等待时间。

公开(公告)号：US08539502B1

公开(公告)日：2013-09-17

申请号：US11787912

申请日：2007-04-18

申请人： Aleksey Sanin ,  Mark Tsimelzon ,  Ian D. Marshall ,  Robert B. Hagmann

发明人： Aleksey Sanin ,  Mark Tsimelzon ,  Ian D. Marshall ,  Robert B. Hagmann

IPC分类号： G06F9/46 ,  G06F7/00

CPC分类号： G06F9/546 ,  G06F2209/548

摘要： The present invention provides a method for obtaining predicable and repeatable output results in a continuous processing system. The method involves processing messages and primitives in accordance with the following rules: (1) Messages are processed in accordance with timestamps, where messages are divided up into “time slices”; (2) message order within a data stream is preserved among messages with the same time stamp; (3) subject to rule #4, for each time slice, a primitive is executed when either the messages within such time slice show up in the input stream for such primitive or the state of the window immediately preceding such primitive changes due to messages within such time slice; and (4) for each time slice, primitives that are dependent on one or more upstream primitives are not executed until such upstream primitives have finished executing messages in such time slice that are queued for processing. If such rules are insufficient to determine the order in which primitives are processed, a deterministic “tie-breaking” rule is then applied.

摘要翻译： 本发明提供一种在连续处理系统中获得可预测和可重复的输出结果的方法。 该方法涉及根据以下规则处理消息和原语：（1）消息根据时间戳进行处理，消息被划分为“时间片”; （2）在具有相同时间戳的消息之间保留数据流内的消息顺序; （3）根据规则＃4，对于每个时间片，当在这样的时间片内的消息在这样的原语的输入流中显示时，或者由于由于消息内部的消息紧接在这样的原始改变之前的窗口的状态，执行原语 这样的时间片; 和（4）对于每个时间片，依赖于一个或多个上游基元的原语不被执行，直到这些上游原语已经完成在排队等待处理的时间片中执行消息。 如果这些规则不足以确定原语被处理的顺序，则应用确定性的“打破破产”规则。

公开(公告)号：US06353860B1

公开(公告)日：2002-03-05

申请号：US08996784

申请日：1997-12-23

申请人： Dwight F. Hare ,  Robert B. Hagmann ,  Michael L. Powell ,  Alan Snyder ,  Peter Vanderbilt

发明人： Dwight F. Hare ,  Robert B. Hagmann ,  Michael L. Powell ,  Alan Snyder ,  Peter Vanderbilt

IPC分类号： G06F954

CPC分类号： G06F9/465

摘要： A variety of methods, apparatus and data structures for managing collections of objects are described. In one aspect of the invention, an object that is intended for use in a distributed object operating environment has a structure including a group designation, a co-activation designation and a co-process designation. The group designation is arranged to identify a group to which the object belongs. The group is defined as a collection of objects which share a common persistent state. The co-activation designation is arranged to identify a co-activation set to which the object belongs. The co-activation set is a collection of objects which are to be activated at the same time. The co-process designation is arranged to identify a co-process set to which the object belongs. The co-process set is a collection of objects which are to be activated within a single process. A various embodiments, a variety of methods of utilizing one or more of these designations to facilitate efficient operation of a distributed computing system are also described. In some applications, a particular object may be conceptually divided into a plurality of sub-objects, with each sub-object having its own portion of persistent memory. In this embodiment, the particular object may only be invoked as a whole, but the object is provided with a mechanism for accessing the selected sub-object in response to a call from a client object that invokes the object and identifies the sub-object in a sub-object field of an object reference that refers to the object. When sub-objects are use, the object references may be arranged to include a host identifier, an object identifier and a sub-object field.

摘要翻译： 描述了用于管理对象集合的各种方法，装置和数据结构。 在本发明的一个方面，旨在用于分布式对象操作环境中的对象具有包括组指定，协同激活指定和协处理指定的结构。 组名称被安排为标识对象所属的组。 该组被定义为共享公共持久状态的对象的集合。 协同激活名称被设置为识别对象所属的共同激活集合。 共同激活集合是要同时激活的对象的集合。 协处理指定被设置为识别对象所属的协同处理集合。 协同处理集合是在单个进程中被激活的对象的集合。 还描述了各种实施例，利用这些指定中的一个或多个来促进分布式计算系统的有效操作的各种方法。 在一些应用中，特定对象可以在概念上被划分为多个子对象，每个子对象具有其自己的持久存储器部分。 在该实施例中，特定对象可以仅作为整体被调用，但是该对象被提供有用于响应于来自调用该对象的客户端对象的调用来访问所选择的子对象的机制，并且识别该子对象 引用对象的对象引用的子对象字段。 当使用子对象时，对象引用可以被布置为包括主机标识符，对象标识符和子对象字段。

公开(公告)号：US5481715A

公开(公告)日：1996-01-02

申请号：US167496

申请日：1993-12-15

申请人： Graham Hamilton ,  Robert B. Hagmann

发明人： Graham Hamilton ,  Robert B. Hagmann

IPC分类号： G06F12/00 ,  G06F9/46 ,  G06F21/00 ,  G06F13/00

CPC分类号： G06F9/547 ,  G06F21/6218 ,  G06F9/465 ,  G06F2211/009 ,  G06F2221/2141

摘要： An apparatus and a method are disclosed whereby a client application can use a trusted "Deputy" application to execute operation calls on several servers on behalf of the client, the Deputy application being able to convince the servers that the deputy application is representing the original client application, and the client thereby reducing the risk of being contaminated by uncontrolled access to an unknown server, while at the same time being able to obtain the desired processing results regardless of the number or location of servers involved in providing the results. The Deputy application is authenticated by the server as representing a user, not a user on a predetermined workstation or as a predetermined member of a particular work group.

摘要翻译： 公开了一种装置和方法，其中客户端应用程序可以使用信任的“副”应用程序来代表客户端在几个服务器上执行操作调用，该副应用能够说服该服务器副代表应用程序代表原始客户端 应用程序和客户端，从而降低被不受控制地访问未知服务器而受到污染的风险，同时能够获得期望的处理结果，而不管提供结果涉及的服务器的数量或位置如何。 副应用程序由服务器认证为表示用户，而不是预定工作站上的用户，或作为特定工作组的预定成员。

公开(公告)号：US06769125B2

公开(公告)日：2004-07-27

申请号：US09968404

申请日：2001-09-28

申请人： Anthony W. Menges ,  Kenneth M. Cavanaugh, III ,  David M. Brownell ,  Robert B. Hagmann ,  Dwight F. Hare ,  Peter Vanderbilt

发明人： Anthony W. Menges ,  Kenneth M. Cavanaugh, III ,  David M. Brownell ,  Robert B. Hagmann ,  Dwight F. Hare ,  Peter Vanderbilt

IPC分类号： G06F954

CPC分类号： G06F9/465

摘要： A number of methods, apparatus, and data structures are disclosed for managing computer processes. In one aspect, a daemon process which manages server processes includes an active server table and a locator service. The locator service can look up and register server processes in the active server table. Furthermore, the locator service can start up server processes. In some embodiments, the locator service includes a look-up object and a server process registration object which perform the tasks of the locator service. In other embodiments, methods for managing server process such as starting and registering the server processes are taught. In one specific method, a daemon process performs a variety of steps in response to receiving a look-up call for a target object. These steps include obtaining a server identifier for the target object, determining the state of a server process, and returning addressing information corresponding to the server process under which the target object will activate. In related method aspects the daemon process will start the server process if it isn't running and/or wait until the server process is running to return the addressing information. In a separate method aspect, a server process self-starts; receiving an object reference for a desired target object, receiving a server process identification number, creating a communications port for itself, forming addressing information for itself, obtaining an object reference for a server process registration object, and registering itself by calling the server process registration object to invoke a register new process operation.

摘要翻译： 公开了用于管理计算机进程的多种方法，装置和数据结构。 一方面，管理服务器进程的守护进程包括活动服务器表和定位器服务。 定位器服务可以在活动服务器表中查找并注册服务器进程。 此外，定位服务可以启动服务器进程。 在一些实施例中，定位器服务包括执行定位器服务的任务的查找对象和服务器进程注册对象。 在其他实施例中，教导了用于管理服务器进程的方法，例如启动和注册服务器进程。 在一个特定方法中，守护进程响应于接收到目标对象的查找调用执行各种步骤。 这些步骤包括获取目标对象的服务器标识符，确定服务器进程的状态，以及返回对应于目标对象将被激活的服务器进程的寻址信息。 在相关方法方面，如果服务器进程未运行，并且/或等待服务器进程运行以返回寻址信息，则守护程序进程将启动服务器进程。 在单独的方法方面，服务器进程自启动; 接收所需目标对象的对象引用，接收服务器进程标识号，为其自身创建通信端口，为其自身形成寻址信息，获取服务器进程注册对象的对象引用，并通过调用服务器进程注册来注册自身 对象调用寄存器新进程操作。

公开(公告)号：US06349342B1

公开(公告)日：2002-02-19

申请号：US08835994

申请日：1997-04-11

申请人： Anthony W. Menges ,  Kenneth M. Cavanaugh, III ,  David M. Brownell ,  Robert B. Hagmann ,  Dwight F. Hare ,  Peter Vanderbilt

发明人： Anthony W. Menges ,  Kenneth M. Cavanaugh, III ,  David M. Brownell ,  Robert B. Hagmann ,  Dwight F. Hare ,  Peter Vanderbilt

IPC分类号： G06F944

CPC分类号： G06F9/465

摘要： A number of methods, apparatus, and data structures are disclosed for managing computer processes. In one aspect, a daemon process which manages server processes includes an active server table and a locator service. The locator service can look up and register server processes in the active server table. Furthermore, the locator service can start up server processes. In some embodiments, the locator service includes a look-up object and a server process registration object which perform the tasks of the locator service. In other embodiments, methods for managing server process such as starting and registering the server processes are taught. In one specific method, a daemon process performs a variety of steps in response to receiving a look-up call for a target object. These steps include obtaining a server identifier for the target object, determining the state of a server process, and returning addressing information corresponding to the server process under which the target object will activate. In related method aspects the daemon process will start the server process if it isn't running and/or wait until the server process is running to return the addressing information. In a separate method aspect, a server process self-starts; receiving an object reference for a desired target object, receiving a server process identification number, creating a communications port for itself, forming addressing information for itself, obtaining an object reference for a server process registration object, and registering itself by calling the server process registration object to invoke a register new process operation.

摘要翻译： 公开了用于管理计算机进程的多种方法，装置和数据结构。 一方面，管理服务器进程的守护进程包括活动服务器表和定位器服务。 定位器服务可以在活动服务器表中查找并注册服务器进程。 此外，定位服务可以启动服务器进程。 在一些实施例中，定位器服务包括执行定位器服务的任务的查找对象和服务器进程注册对象。 在其他实施例中，教导了用于管理服务器进程的方法，例如启动和注册服务器进程。 在一个特定方法中，守护进程响应于接收到目标对象的查找调用执行各种步骤。 这些步骤包括获取目标对象的服务器标识符，确定服务器进程的状态，以及返回对应于目标对象将被激活的服务器进程的寻址信息。 在相关方法方面，如果服务器进程未运行，并且/或等待服务器进程运行以返回寻址信息，则守护程序进程将启动服务器进程。 在单独的方法方面，服务器进程自启动; 接收所需目标对象的对象引用，接收服务器进程标识号，为其自身创建通信端口，为其自身形成寻址信息，获取服务器进程注册对象的对象引用，并通过调用服务器进程注册来注册自身 对象调用寄存器新进程操作。