会员体验
专利管家(专利管理)
工作空间(专利管理)
风险监控(情报监控)
数据分析(专利分析)
侵权分析(诉讼无效)
联系我们
交流群
官方交流:
QQ群: 891211   
微信请扫码    >>>
现在联系顾问~
热词
    • 1. 发明申请
    • CONSISTENCY SENSITIVE STREAMING OPERATORS
    • 一致的敏感流程操作员
    • US20090125635A1
    • 2009-05-14
    • US11937118
    • 2007-11-08
    • Roger S. BargaJonathan D. GoldsteinMohamed AliMingsheng Hong
    • Roger S. BargaJonathan D. GoldsteinMohamed AliMingsheng Hong
    • G06F15/16
    • G06F11/0793G06F11/0721
    • A new approach for handling stream imperfections based on speculative execution involves the retraction of incorrect events facilitated using operators to remove speculatively produced incorrect output. Additionally, parameters are disclosed that define a spectrum of consistency levels. A first parameter, maximum blocking time, exposes a tradeoff between a degree of speculation and latency. A second parameter, the maximum time data is remembered before being purged from the system, exposes a tradeoff between state size and correctness. Varying these two parameters produces a spectrum of consistency levels (e.g., strong, middle, weak) which address the specific tradeoffs built into other systems. Retraction is accomplished using operators that include Select, AlterLifetime, Join, Sum, Align, and Finalize.
    • 基于推测执行的处理流瑕疵的新方法涉及使用运算符来消除误导事件的撤销,以消除推测出错的输出。 另外,公开了定义一致性级别的参数。 第一个参数,最大阻塞时间,暴露了一定程度的推测和延迟之间的折衷。 第二个参数是在从系统清除之前记住的最大时间数据暴露了状态大小和正确性之间的折衷。 改变这两个参数产生了一系列一致性级别(例如,强,中,弱),其解决了内置到其他系统中的特定权衡。 使用包括Select,AlterLifetime,Join,Sum,Align和Finalize的操作符来实现退回。
    • 2. 发明授权
    • Consistency sensitive streaming operators
    • 一致性敏感的流媒体运营商
    • US08315990B2
    • 2012-11-20
    • US11937118
    • 2007-11-08
    • Roger S BargaJonathan D GoldsteinMohamed AliMingsheng Hong
    • Roger S BargaJonathan D GoldsteinMohamed AliMingsheng Hong
    • G06F17/30
    • G06F11/0793G06F11/0721
    • A new approach for handling stream imperfections based on speculative execution involves the retraction of incorrect events facilitated using operators to remove speculatively produced incorrect output. Additionally, parameters are disclosed that define a spectrum of consistency levels. A first parameter, maximum blocking time, exposes a tradeoff between a degree of speculation and latency. A second parameter, the maximum time data is remembered before being purged from the system, exposes a tradeoff between state size and correctness. Varying these two parameters produces a spectrum of consistency levels (e.g., strong, middle, weak) which address the specific tradeoffs built into other systems. Retraction is accomplished using operators that include Select, AlterLifetime, Join, Sum, Align, and Finalize.
    • 基于推测执行的处理流瑕疵的新方法涉及使用运算符来消除误导事件的撤销,以消除推测出错的输出。 另外,公开了定义一致性级别的参数。 第一个参数,最大阻塞时间,暴露了一定程度的推测和延迟之间的折衷。 第二个参数是在从系统清除之前记住的最大时间数据暴露了状态大小和正确性之间的折衷。 改变这两个参数产生了一系列一致性级别(例如,强,中,弱),其解决了内置到其他系统中的特定权衡。 使用包括Select,AlterLifetime,Join,Sum,Align和Finalize的操作符来实现退回。
    • 3. 发明申请
    • TEMPORAL EVENT STREAM MODEL
    • 时间流动模型
    • US20090125550A1
    • 2009-05-14
    • US11937011
    • 2007-11-08
    • Roger S. BargaJonathan D. GoldsteinMohamed AliMingsheng Hong
    • Roger S. BargaJonathan D. GoldsteinMohamed AliMingsheng Hong
    • G06F7/00
    • G06Q40/06G06F9/542G06F2209/544
    • Disclosed is a temporal stream model that provides support both for query language semantics and consistency guarantees, simultaneously. A data stream is modeled as a time varying relation. The data stream model incorporates a temporal data perspective, and defines a clear separation in different notions of time in streaming applications. The temporal stream model further refines the conventional application time into two temporal dimensions of valid time and occurrence time, and utilizes system time (the clock of the stream processor) for modeling out-of-order event delivery but thereby providing three temporal dimensions. The methods for assigning timestamps and quantifying latency form the basis for defining a spectrum of consistency levels. Based on the selected consistency level, an output can be produced. The utilization of system time facilitates the retraction of incorrect output and the insertion of the correct revised output.
    • 公开了一种时间流模型,同时为查询语言语义和一致性保证提供支持。 数据流被建模为时变关系。 数据流模型结合了时间数据透视图,并且在流媒体应用中定义了不同时间观念的明确分离。 时间流模型进一步将传统的应用时间细化为有效时间和发生时间的两个时间维度,并利用系统时间(流处理器的时钟)来建模无序事件传递,从而提供三个时间维度。 分配时间戳和量化延迟的方法是定义一致性级别谱的基础。 基于所选的一致性级别,可以产生输出。 系统时间的利用有助于收回不正确的输出并插入正确的修正输出。
    • 4. 发明授权
    • Streaming operator placement for distributed stream processing
    • 用于分布式流处理的流式操作员位置
    • US08060614B2
    • 2011-11-15
    • US12141914
    • 2008-06-19
    • Jonathan D. GoldsteinRoger S. BargaMirek RiedewaldMingsheng Hong
    • Jonathan D. GoldsteinRoger S. BargaMirek RiedewaldMingsheng Hong
    • G06F15/16
    • G06F9/5083
    • A streaming operator assignment system and method for determining a streaming operator assignment that minimizes overload in a data processing system. Embodiments of the streaming operator assignment system include an optimization goals definition module, which defines optimization goals in terms of fundamental quantities that system administrators and application writers want to control, such as minimizing the worst case latency over all periods of time, or minimizing how much the system is backlogged with work. Embodiments of the streaming operator assignment system also include an optimization goals solution module that optimizes and solves a selected optimization goal. A specialized optimization technique is used to find the best operator (or load) assignment using the optimization goals to measure of the value of the assignment. This technique minimizes an optimization goal by iterating over all possible operators assignments over all possible nodes to find the operator assignment that minimizes the desired optimization goal.
    • 一种用于确定使数据处理系统中的过载最小化的流操作员分配的流操作员分配系统和方法。 流操作者分配系统的实施例包括优化目标定义模块,其定义系统管理员和应用程序编写者想要控制的基本量的优化目标,例如最小化所有时间段内的最坏情况延迟,或最小化多少 系统用工作积压。 流式操作员分配系统的实施例还包括优化和解决所选优化目标的优化目标解决方案模块。 使用专门的优化技术来使用优化目标来找到最佳的运算符(或加载)分配,以度量分配值。 该技术通过遍历所有可能节点上的所有可能的运算符分配来最小化优化目标,以找到最小化期望的优化目标的运算符分配。
    • 5. 发明申请
    • STREAMING OPERATOR PLACEMENT FOR DISTRIBUTED STREAM PROCESSING
    • 用于分布式流程处理的流水线操作者布置
    • US20090319687A1
    • 2009-12-24
    • US12141914
    • 2008-06-19
    • Jonathan D. GoldsteinRoger S. BargaMirek RiedewaldMingsheng Hong
    • Jonathan D. GoldsteinRoger S. BargaMirek RiedewaldMingsheng Hong
    • G06F15/16
    • G06F9/5083
    • A streaming operator assignment system and method for determining a streaming operator assignment that minimizes overload in a data processing system. Embodiments of the streaming operator assignment system include an optimization goals definition module, which defines optimization goals in terms of fundamental quantities that system administrators and application writers want to control, such as minimizing the worst case latency over all periods of time, or minimizing how much the system is backlogged with work. Embodiments of the streaming operator assignment system also include an optimization goals solution module that optimizes and solves a selected optimization goal. A specialized optimization technique is used to find the best operator (or load) assignment using the optimization goals to measure of the value of the assignment. This technique minimizes an optimization goal by iterating over all possible operators assignments over all possible nodes to find the operator assignment that minimizes the desired optimization goal.
    • 一种用于确定使数据处理系统中的过载最小化的流操作员分配的流操作员分配系统和方法。 流媒体操作员分配系统的实施例包括优化目标定义模块,其定义系统管理员和应用程序编写者想要控制的基本量的优化目标,例如最小化所有时间段内的最坏情况延迟,或最小化多少 系统用工作积压。 流式操作员分配系统的实施例还包括优化和解决所选优化目标的优化目标解决方案模块。 使用专门的优化技术来使用优化目标来找到最佳的运算符(或加载)分配,以度量分配值。 该技术通过遍历所有可能节点上的所有可能的运算符分配来最小化优化目标,以找到最小化期望的优化目标的运算符分配。
    • 6. 发明申请
    • TRANSLATION OF STREAMING QUERIES INTO SQL QUERIES
    • 将流程查询翻译成SQL QUERIES
    • US20090319501A1
    • 2009-12-24
    • US12144698
    • 2008-06-24
    • Jonathan David GoldsteinMingsheng Hong
    • Jonathan David GoldsteinMingsheng Hong
    • G06F7/06G06F17/30
    • G06F16/24568G06F16/2452G06F16/258
    • A query translation system and method for processing a streaming language query on existing or stored data. The streaming language query is applied against a data stream log by first translating the streaming language query into a database management system query (such as a SQL query) and then applying the translated streaming language query against the data stream log. Embodiments of the query translation system and method include a bitemporal converter that converts a bitemporal data stream log into a canonical history table format. Once in this format, embodiments of the query translation system and method translate a streaming language query into a SQL query. A categorization of each of the streaming operators that make up the streaming language query is performed to determine which translation technique to use. In general, one of three general translation techniques is used based on these categorizations of the streaming operators.
    • 用于处理对现有或存储的数据的流式语言查询的查询翻译系统和方法。 通过首先将流式语言查询翻译成数据库管理系统查询(例如SQL查询),然后针对数据流日志应用翻译的流式语言查询,对数据流日志应用流式语言查询。 查询翻译系统和方法的实施例包括将时间数据流日志转换为规范历史表格式的时间转换器。 一旦采用这种格式,查询翻译系统和方法的实施例将流式语言查询转换成SQL查询。 执行构成流式语言查询的每个流操作符的分类,以确定要使用的翻译技术。 一般来说,基于流操作员的这些分类使用三种一般翻译技术之一。