会员体验
专利管家(专利管理)
工作空间(专利管理)
风险监控(情报监控)
数据分析(专利分析)
侵权分析(诉讼无效)
联系我们
交流群
官方交流:
QQ群: 891211   
微信请扫码    >>>
现在联系顾问~
热词
    • 3. 发明授权
    • Continuous processing language for real-time data streams
    • 用于实时数据流的连续处理语言
    • US08396886B1
    • 2013-03-12
    • US11346119
    • 2006-02-02
    • Mark TsimelzonAleksey SaninRajeev MotwaniGlenn Robert SeidmanGayatri Patel
    • Mark TsimelzonAleksey SaninRajeev MotwaniGlenn Robert SeidmanGayatri Patel
    • G06F7/00G06F17/30
    • G06F17/30533G06F17/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的,并且包括用于定义命名窗口(可以在任意数量的查询中使用)的子句; 用于检测模式的子句,以及用于将数据流数据与数据库表相关联的数据库子查询。
    • 4. 发明授权
    • Use of pseudonyms vs. real names
    • 使用假名与实名
    • US07107447B2
    • 2006-09-12
    • US10418904
    • 2003-04-17
    • Aleksey SaninConor P. Cahill
    • Aleksey SaninConor P. Cahill
    • H04L9/00
    • H04L51/28H04L63/0407H04L63/08H04L63/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服务的链接的联合网络服务的服务,而不向其他用户暴露真实的用户名。
    • 6. 发明申请
    • Metadata database lookup system
    • 元数据查询系统
    • US20050060315A1
    • 2005-03-17
    • US10666883
    • 2003-09-16
    • Aleksey Sanin
    • Aleksey Sanin
    • G06F20060101G06F7/00G06F17/30
    • 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。
    • 7. 发明授权
    • Method for obtaining repeatable and predictable output results in a continuous processing system
    • 在连续处理系统中获得可重复和可预测输出的方法
    • US08539502B1
    • 2013-09-17
    • US11787912
    • 2007-04-18
    • Aleksey SaninMark TsimelzonIan D. MarshallRobert B. Hagmann
    • Aleksey SaninMark TsimelzonIan D. MarshallRobert B. Hagmann
    • G06F9/46G06F7/00
    • G06F9/546G06F2209/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)对于每个时间片,依赖于一个或多个上游基元的原语不被执行,直到这些上游原语已经完成在排队等待处理的时间片中执行消息。 如果这些规则不足以确定原语被处理的顺序,则应用确定性的“打破破产”规则。
    • 8. 发明授权
    • Method for guaranteeing processing of messages in a continuous processing system
    • 确保连续处理系统中消息处理的方法
    • US07818757B1
    • 2010-10-19
    • US11487796
    • 2006-07-17
    • Mark TsimelzonAleksey SaninAlexander Zeyliger
    • Mark TsimelzonAleksey SaninAlexander Zeyliger
    • G06F3/00G06F9/44G06F9/46G06F13/00G06F11/00G06F15/16
    • G06F11/1438G06F9/546G06F11/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.
    • 处理消息的方法确保进入连续处理系统的每个消息都被完全处理,即使在系统内发生故障的情况下也是如此。 消息被推送通过执行计划,包括一组处理消息的连接的“原语”,其中原语可以分布在一组服务器上。 消息按照协议进行推送,该协议不允许未处理的消息在输入源,原语之间以及执行计划中的输出源之间永久丢失。 与每个基元相关联的输入队列,输出队列和状态(如果有)保存在选定检查点的持久存储器中。 如果服务器发生故障,则服务器再次启动后,将该服务器上的原语恢复到上次适用检查点保存的输入队列,输出队列和状态。
    • 10. 发明授权
    • System and method for synchronizing message processing in a continuous processing system
    • 用于在连续处理系统中同步消息处理的系统和方法
    • US08560495B1
    • 2013-10-15
    • US11820111
    • 2007-06-18
    • Aleksey SaninIan D. Marshall
    • Aleksey SaninIan D. Marshall
    • G06F7/00G06F17/00
    • G06F9/522G06F8/458G06F17/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.
    • 提供了一种系统和方法,用于在受到基本元素影响的执行图形的区域中同步消息的处理,并且具有潜在的实质性延迟。 连续处理系统识别具有实质性延迟潜力的原语。 对于不在循环中的每个潜在延迟的原语,连续处理系统在这样的原语下游创建“时区”。 潜在延迟的基元的输出是时区的输入。 连续处理系统然后识别到时区的所有其他输入,并在这样的输入之间放置一个同步器。 在潜在延迟的原语在循环内的情况下,时区包括这样的原语,以及这些原语下游的所有原语。