会员体验
专利管家(专利管理)
工作空间(专利管理)
风险监控(情报监控)
数据分析(专利分析)
侵权分析(诉讼无效)
联系我们
交流群
官方交流:
QQ群: 891211   
微信请扫码    >>>
现在联系顾问~
热词
    • 1. 发明申请
    • CHANNEL-BASED RUNTIME ENGINE FOR STREAM PROCESSING
    • 用于流程处理的基于通道的运行型发动机
    • US20100318768A1
    • 2010-12-16
    • US12485592
    • 2009-06-16
    • Eric BouilletHanhua FengZhen LiuAnton V. Riabov
    • Eric BouilletHanhua FengZhen LiuAnton V. Riabov
    • G06F9/40G06F9/30
    • G06Q10/06G06F9/4494
    • An apparatus, including a memory device for storing a program, and a processor in communication with the memory device, the processor operative with the program to facilitate design of a stream processing flow that satisfies an objective, wherein the stream processing flow includes at least three processing groups, wherein a first processing group includes a data source and an operator, a second processing group includes a data source and an operator and a third processing group includes a join operator at its input and another operator, wherein data inside each group is organized by channels and each channel is a sequence of data, wherein an operator producing a data channel does not generate new data for the channel until old data of the channel is received by all other operators in the same group, and wherein data that flows from the first and second groups to the third group is done asynchronously and is stored in a queue if not ready for processing by an operator of the third group, and deploy the stream processing flow in a concurrent computing system to produce an output.
    • 一种装置,包括用于存储程序的存储装置和与存储装置通信的处理器,所述处理器与程序一起操作以便于满足目标的流处理流程的设计,其中流处理流程包括至少三个 处理组,其中第一处理组包括数据源和操作者,第二处理组包括数据源和操作者,第三处理组在其输入处包括加入运算符和另一运算符,其中组内每个组内的数据被组织 每个信道是一个数据序列,其中产生数据信道的运算符不产生信道的新数据,直到信道的旧数据被同一组中的所有其他运算符接收,并且其中从 第一组和第二组到第三组是异步完成的,如果没有准备好进行处理,则由第三组的运算符存储在队列中 p并且在并发计算系统中部署流处理流以产生输出。
    • 8. 发明授权
    • Channel-based runtime engine for stream processing
    • 基于通道的运行时引擎,用于流处理
    • US08380965B2
    • 2013-02-19
    • US12485592
    • 2009-06-16
    • Eric BouilletHanhua FengZhen LiuAnton V. Riabov
    • Eric BouilletHanhua FengZhen LiuAnton V. Riabov
    • G06F9/00
    • G06Q10/06G06F9/4494
    • An apparatus to facilitate design of a stream processing flow that satisfies an objective, wherein the flow includes at least three processing groups, wherein a first processing group includes a data source and an operator, a second processing group includes a data source and an operator and a third processing group includes a join operator at its input and another operator, wherein data inside each group is organized by channels and each channel is a sequence of data, wherein an operator producing a data channel does not generate new data for the channel until old data of the channel is received by all other operators in the same group, and wherein data that flows from the first and second groups to the third group is done asynchronously and is stored in a queue if not ready for processing by an operator of the third group.
    • 一种便于设计满足目标的流处理流的装置,其中所述流包括至少三个处理组,其中第一处理组包括数据源和操作者,第二处理组包括数据源和操作符, 第三处理组包括其输入端的加入运算符和另一运算符,其中每组内的数据由信道组织,并且每个信道是数据序列,其中产生数据信道的运算符不会在该信道之前生成用于该信道的新数据,直到旧 信道的数据由同一组中的所有其他运营商接收,并且其中从第一组和第二组流向第三组的数据是异步完成的,并且如果没有准备好被第三组的运营商处理,则将其存储在队列中 组。