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

1. 发明授权

US08539502B1 Method for obtaining repeatable and predictable output results in a continuous processing system 有权
标题翻译：在连续处理系统中获得可重复和可预测输出的方法
公开(公告)号：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）对于每个时间片，依赖于一个或多个上游基元的原语不被执行，直到这些上游原语已经完成在排队等待处理的时间片中执行消息。如果这些规则不足以确定原语被处理的顺序，则应用确定性的“打破破产”规则。

2. 发明授权

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

3. 发明授权

US07818313B1 Method for distributing processing of queries over a cluster of servers in a continuous processing system 有权
标题翻译：在连续处理系统中通过服务器集群分发处理查询的方法
公开(公告)号：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.
摘要翻译：在连续计算系统中，用于在服务器集群上处理一组注册查询的方法包括创建用于在服务器集群上处理一组查询的执行计划，其中连续计算系统通过分析查询的语义和要求，以确定如何在集群中分发处理。查询的分析可以包括确定用于查询的输入消息是否可以彼此独立地被处理，查询的输入消息是否可被划分成可以被彼此独立地处理的组，查询是否包括聚合器功能，以及查询是否包含子查询。

4. 发明授权

US08396886B1 Continuous processing language for real-time data streams 有权
标题翻译：用于实时数据流的连续处理语言
公开(公告)号：US08396886B1
公开(公告)日：2013-03-12
申请号：US11346119
申请日：2006-02-02
申请人： Mark Tsimelzon , Aleksey Sanin , Rajeev Motwani , Glenn Robert Seidman , Gayatri Patel
发明人： Mark Tsimelzon , Aleksey Sanin , Rajeev Motwani , Glenn Robert Seidman , Gayatri Patel
IPC分类号： G06F7/00 , G06F17/30
CPC分类号： G06F17/30533 , G06F17/30516
摘要： A computer software language capable of expressing registered queries that operate on one more or more data streams continuously. The language of the present invention is based on a publish/subscribe model in that queries subscribe to data streams and publish to data streams. Also, the language of the present invention can express queries that operate directly on data streams. Since queries expressed in the language of the present invention may be executed continuously and directly on data streams, the language includes a clause for specifying time-based and/or row-based windows for the input data stream. Operations are then performed on the data within such windows. In one embodiment, the language is also SQL-like and includes a clause for defining named windows (which can be used in any number of queries); a clause for detecting a pattern, and correlated database subqueries for correlating data stream data with database tables.
摘要翻译：一种能够连续地表达对一个或多个数据流进行操作的注册查询的计算机软件语言。本发明的语言基于发布/订阅模型，其中查询订阅数据流并发布到数据流。此外，本发明的语言可以表达直接对数据流进行操作的查询。由于以本发明的语言表示的查询可以连续且直接地在数据流上执行，所以该语言包括用于为输入数据流指定基于时间的和/或基于行的窗口的子句。然后对这些窗口内的数据执行操作。在一个实施例中，语言也是类似SQL的，并且包括用于定义命名窗口（可以在任意数量的查询中使用）的子句; 用于检测模式的子句，以及用于将数据流数据与数据库表相关联的数据库子查询。

5. 发明授权

US07818757B1 Method for guaranteeing processing of messages in a continuous processing system 有权
标题翻译：确保连续处理系统中消息处理的方法
公开(公告)号：US07818757B1
公开(公告)日：2010-10-19
申请号：US11487796
申请日：2006-07-17
申请人： Mark Tsimelzon , Aleksey Sanin , Alexander Zeyliger
发明人： Mark Tsimelzon , Aleksey Sanin , Alexander Zeyliger
IPC分类号： G06F3/00 , G06F9/44 , G06F9/46 , G06F13/00 , G06F11/00 , G06F15/16
CPC分类号： G06F11/1438 , G06F9/546 , G06F11/1474
摘要： A method for processing messages ensures that every message that enters a continuous processing system is fully processed in its entirety, even in the event of a failure within the system. Messages are pushed through an execution plan that includes a set of connected “primitives” that process the message, where the primitives may be distributed across a group of servers. Messages are pushed through in accordance with a protocol that does not permit unprocessed messages to be permanently lost as they travel from input sources, between primitives, and to output sources within the execution plan. The input queue, output queue, and state (if any) associated with each primitive are saved in persistent storage at select checkpoints. If a failure occurs on a server, the server, after it starts up again, restores the primitives on that server to the input queues, output queues, and states saved at the last applicable checkpoint.
摘要翻译：处理消息的方法确保进入连续处理系统的每个消息都被完全处理，即使在系统内发生故障的情况下也是如此。消息被推送通过执行计划，包括一组处理消息的连接的“原语”，其中原语可以分布在一组服务器上。消息按照协议进行推送，该协议不允许未处理的消息在输入源，原语之间以及执行计划中的输出源之间永久丢失。与每个基元相关联的输入队列，输出队列和状态（如果有）保存在选定检查点的持久存储器中。如果服务器发生故障，则服务器再次启动后，将该服务器上的原语恢复到上次适用检查点保存的输入队列，输出队列和状态。

6. 发明授权

US07383253B1 Publish and subscribe capable continuous query processor for real-time data streams 有权
标题翻译：发布和订阅能力强的连续查询处理器实时数据流
公开(公告)号：US07383253B1
公开(公告)日：2008-06-03
申请号：US11015963
申请日：2004-12-17
申请人： Mark Tsimelzon , Aleksey Sanin , Rajeev Motwani , Glenn Robert Seidman , Gayatri Patel
发明人： Mark Tsimelzon , Aleksey Sanin , Rajeev Motwani , Glenn Robert Seidman , Gayatri Patel
IPC分类号： G06F17/30
CPC分类号： G06F17/30516 , Y10S707/918 , Y10S707/99933
摘要： A Continuous Query Processor processes queries on continuously updating data sources or data streams and includes a Publication Manager for accepting published structured elements of data from data stream Publishers, a Subscription Manager for giving structured elements of data to one or more data stream Subscribers, a Query Module Manager for processing queries represented by Query Modules, a Query Module Store for maintaining deployed Query Modules, a Query Primitive Manager performing processing for various primitives that comprise a Query Module, and a Schedule Manager for coordinating when a primitive within a Query Module gets processed in order to maintain that each continuous query is continuously updated immediately upon the arrival of structured element data affecting any part of a continuous query.
摘要翻译：连续查询处理器处理对持续更新数据源或数据流的查询，并包括一个出版管理器，用于接受数据流发布者发布的数据结构元素，订阅管理器，用于向一个或多个数据流订阅者提供数据结构化元素，查询用于处理由查询模块表示的查询的模块管理器，用于维护部署的查询模块的查询模块存储库，执行针对构成查询模块的各种图元的处理的查询基元管理器，以及用于在查询模块中的原语处理时进行协调的计划管理器以便保持在影响连续查询的任何部分的结构化元素数据到达时立即连续更新每个连续查询。

7. 发明授权

US08560495B1 System and method for synchronizing message processing in a continuous processing system 有权
标题翻译：用于在连续处理系统中同步消息处理的系统和方法
公开(公告)号：US08560495B1
公开(公告)日：2013-10-15
申请号：US11820111
申请日：2007-06-18
申请人： Aleksey Sanin , Ian D. Marshall
发明人： Aleksey Sanin , Ian D. Marshall
IPC分类号： G06F7/00 , G06F17/00
CPC分类号： G06F9/522 , G06F8/458 , G06F17/30516
摘要： A system and method to synchronize the processing of messages in areas of an execution graph affected by primitives with potential for substantial delay is provided. A continuous processing system identifies primitives with potential for substantial delay. For each potentially-delayed primitive that is not in a loop, the continuous processing system creates a “timezone” downstream of such primitive. The output(s) of the potentially-delayed primitive is an input to the timezone. The continuous processing system then identifies all other inputs to the timezone and places a synchronizer across such inputs. In cases where the potentially-delayed primitive is within a loop, the timezone includes such primitive, as well all primitives downstream of such primitive.
摘要翻译：提供了一种系统和方法，用于在受到基本元素影响的执行图形的区域中同步消息的处理，并且具有潜在的实质性延迟。连续处理系统识别具有实质性延迟潜力的原语。对于不在循环中的每个潜在延迟的原语，连续处理系统在这样的原语下游创建“时区”。潜在延迟的基元的输出是时区的输入。连续处理系统然后识别到时区的所有其他输入，并在这样的输入之间放置一个同步器。在潜在延迟的原语在循环内的情况下，时区包括这样的原语，以及这些原语下游的所有原语。

8. 发明授权

US07107447B2 Use of pseudonyms vs. real names 有权
标题翻译：使用假名与实名
公开(公告)号：US07107447B2
公开(公告)日：2006-09-12
申请号：US10418904
申请日：2003-04-17
申请人： Aleksey Sanin , Conor P. Cahill
发明人： Aleksey Sanin , Conor P. Cahill
IPC分类号： H04L9/00
CPC分类号： H04L51/28 , H04L63/0407 , H04L63/08 , H04L63/0807
摘要： An apparatus and method is provided for allowing users to share services without sharing identities. Specifically, the apparatus and method allow users to share pseudonyms instead of actual user names, thus protecting both users from unwanted emails, IM messages, and the like. The invention provides an introduction scheme, which comprises a simple and secure way of establishing a user to user link. A preferred embodiment incorporates services of a linked federation network service, such as AOL's Liberty Alliance service, without exposing real user names to other users.
摘要翻译：提供了一种用于允许用户在不共享身份的情况下共享服务的装置和方法。具体地，该装置和方法允许用户共享假名而不是实际的用户名，从而保护用户免受不必要的电子邮件，IM消息等的影响。本发明提供一种引入方案，其包括将用户建立到用户链接的简单和安全的方式。优选实施例包括诸如AOL的Liberty Alliance服务的链接的联合网络服务的服务，而不向其他用户暴露真实的用户名。

9. 发明授权

US07500262B1 Implementing single sign-on across a heterogeneous collection of client/server and web-based applications 有权
标题翻译：在异构的客户端/服务器和基于Web的应用程序集合中实现单点登录
公开(公告)号：US07500262B1
公开(公告)日：2009-03-03
申请号：US10424995
申请日：2003-04-29
申请人： Aleksey Sanin , Christopher Toomey , Alan Keister , Andrew L. Wick , Robert Watkins , Donald Eaves , Xiaopeng Zhang , Russell Richards
发明人： Aleksey Sanin , Christopher Toomey , Alan Keister , Andrew L. Wick , Robert Watkins , Donald Eaves , Xiaopeng Zhang , Russell Richards
IPC分类号： G04F7/04 , G06F7/04 , G06F15/16 , H04K1/00
CPC分类号： H04L63/08 , G06F21/41 , G06Q20/3674 , H04L9/3234 , H04L9/3271 , H04L63/0815 , H04W12/06
摘要： Leveraging an established authenticated session in obtaining authentication to a client application includes receiving a request for access to a client application requiring authentication of a requestor and determining whether there exist characteristics of leverageable authentications corresponding to established sessions having an authenticated state at a time of the determination. When the determination reveals characteristics of at least one leverageable authentication corresponding to an established session, and attempt is made to obtain access for the requester to the client application based on the at least one leverageable authentication, and the requestor is provided with a notification related to the attempt to obtain access for the requester to the client application.
摘要翻译：利用建立的认证会话来获得对客户端应用的认证包括：接收对需要认证请求者的客户端应用的访问请求，并且确定在确定时是否存在对应于具有认证状态的已建立会话的可执行认证的特征。当确定揭示与所建立的会话相对应的至少一个可操作认证的特征时，并且尝试基于所述至少一个可操作认证来获得对客户应用的请求者的访问，并且向请求者提供与尝试获取请求者访问客户端应用程序。

10. 发明申请

US20050060315A1 Metadata database lookup system 审中-公开
标题翻译：元数据查询系统
公开(公告)号：US20050060315A1
公开(公告)日：2005-03-17
申请号：US10666883
申请日：2003-09-16
申请人： Aleksey Sanin
发明人： Aleksey Sanin
IPC分类号： G06F20060101 , G06F7/00 , G06F17/30
CPC分类号： G06F16/951
摘要： A metadata database lookup system provides a database is that contains a cross-reference of metadata information to a service provider ID number or universal resource identifier (URI). A service provider ID number is keyed to metadata information about a specific resource from a service provider. The metadata information can contain a description of the resource, the universal resource locator (URL) for the resource, and any other pertinent information that may be associated with the resource. The invention uses a constant ID number for a service provider and its resource. A resource requestor uses the ID number for the desired service provider resource. The ID number is cross referenced with the proper metadata information for the resource and the resource requestor uses the metadata information as needed and accesses the resource using the URL in the metadata. The resource requester is unaffected by updates to a resource's description or address by the service provider. The database tracks the metadata and URIs for resources for a specific service provider or resources for multiple service providers.
摘要翻译：元数据数据库查找系统提供了包含元数据信息与服务提供商ID号或通用资源标识符（URI）的交叉引用的数据库。服务提供商ID号码被关联到来自服务提供商的关于特定资源的元数据信息。元数据信息可以包含资源的描述，资源的通用资源定位符（URL）以及可能与资源相关联的任何其他相关信息。本发明使用用于服务提供商及其资源的常数ID号。资源请求者使用所需服务提供商资源的ID号。 ID号与资源的适当元数据信息交叉引用，资源请求者根据需要使用元数据信息，并使用元数据中的URL访问资源。资源请求者不受服务提供商对资源描述或地址的更新的影响。数据库跟踪特定服务提供商或多个服务提供商的资源的资源的元数据和URI。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式