会员体验
专利管家(专利管理)
工作空间(专利管理)
风险监控(情报监控)
数据分析(专利分析)
侵权分析(诉讼无效)
联系我们
交流群
官方交流:
QQ群: 891211   
微信请扫码    >>>
现在联系顾问~
热词
    • 2. 发明申请
    • VISUALIZING QUERY RESULTS IN STREAM PROCESSING SYSTEMS
    • 在流程处理系统中查看查询结果
    • US20110302196A1
    • 2011-12-08
    • US12827419
    • 2010-06-30
    • Eric BouilletHanhua FengAnton V. Riabov
    • Eric BouilletHanhua FengAnton V. Riabov
    • G06F17/30
    • G06F17/30516
    • In a method for visualizing query results in stream processing systems, a visualization service receives a query from a client to visualize data in a stream processing application. The query is sent from the visualization service to a query-able operator of the stream processing application. At the query-able operator, an operation is performed using history data in the query-able operator to produce a first result that satisfies the query and the first result is sent to the visualization service. At the query-able operator, another operation is performed using new data received by the query-able operator to produce a second result that satisfies the query and the second result is sent to the visualization service. The first and second results are output from the visualization service to the client.
    • 在用于在流处理系统中可视化查询结果的方法中,可视化服务从客户端接收查询以在流处理应用中可视化数据。 查询从可视化服务发送到流处理应用程序的可查询操作员。 在可查询操作员处,使用可查询操作符中的历史数据执行操作,以产生满足查询的第一个结果,并将第一个结果发送给可视化服务。 在可查询操作员处,使用由可查询操作者接收的新数据执行另一操作,以产生满足查询的第二结果,并将第二结果发送给可视化服务。 第一和第二个结果从可视化服务输出到客户端。
    • 3. 发明申请
    • 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并且在并发计算系统中部署流处理流以产生输出。
    • 4. 发明授权
    • Visualizing query results in stream processing systems
    • 在流处理系统中可视化查询结果
    • US08290939B2
    • 2012-10-16
    • US12827419
    • 2010-06-30
    • Eric BouilletHanhua FengAnton V Riabov
    • Eric BouilletHanhua FengAnton V Riabov
    • G06F7/00
    • G06F17/30516
    • In a method for visualizing query results in stream processing systems, a visualization service receives a query from a client to visualize data in a stream processing application. The query is sent from the visualization service to a query-able operator of the stream processing application. At the query-able operator, an operation is performed using history data in the query-able operator to produce a first result that satisfies the query and the first result is sent to the visualization service. At the query-able operator, another operation is performed using new data received by the query-able operator to produce a second result that satisfies the query and the second result is sent to the visualization service. The first and second results are output from the visualization service to the client.
    • 在用于在流处理系统中可视化查询结果的方法中,可视化服务从客户端接收查询以在流处理应用中可视化数据。 查询从可视化服务发送到流处理应用程序的可查询操作员。 在可查询操作员处,使用可查询操作符中的历史数据执行操作,以产生满足查询的第一个结果,并将第一个结果发送给可视化服务。 在可查询操作员处,使用由可查询操作者接收的新数据执行另一操作,以产生满足查询的第二结果,并将第二结果发送给可视化服务。 第一和第二个结果从可视化服务输出到客户端。
    • 5. 发明授权
    • 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.
    • 一种便于设计满足目标的流处理流的装置,其中所述流包括至少三个处理组,其中第一处理组包括数据源和操作者,第二处理组包括数据源和操作符, 第三处理组包括其输入端的加入运算符和另一运算符,其中每组内的数据由信道组织,并且每个信道是数据序列,其中产生数据信道的运算符不会在该信道之前生成用于该信道的新数据,直到旧 信道的数据由同一组中的所有其他运营商接收,并且其中从第一组和第二组流向第三组的数据是异步完成的,并且如果没有准备好被第三组的运营商处理,则将其存储在队列中 组。