DISTRIBUTED AND ADAPTIVE COMPUTER NETWORK ANALYTICS
    1.
    发明申请
    DISTRIBUTED AND ADAPTIVE COMPUTER NETWORK ANALYTICS 审中-公开
    分布式和自适应计算机网络分析

    公开(公告)号:US20160197799A1

    公开(公告)日:2016-07-07

    申请号:US14589953

    申请日:2015-01-05

    Abstract: A network analytics controller in a computer network receives specification of a network analysis task. The controller creates maplets. Each maplet corresponds to an agent executing on a network node in the computer network. Each maplet specifies the network data collection configuration, collected data processing, and processed data reporting to be performed to support the network analysis task at the node executing the corresponding agent. The controller communicates the maplet corresponding to the agent over the computer network to each agent. Each agent receiving a maplet configures its corresponding network node for network data collection, collected data processing, and processed data reporting in accordance with the received maplet. Each agent receiving a maplet collects and processes network data, and reports the processed data to the controller, in accordance with the configuration. The controller aggregates, as the result of the network analysis task, the data reported from each agent.

    Abstract translation: 计算机网络中的网络分析控制器接收网络分析任务的规范。 控制器创建maplets。 每个映射对应于在计算机网络中的网络节点上执行的代理。 每个maplet指定要执行的网络数据收集配置,收集的数据处理和处理的数据报告,以支持执行相应代理的节点处的网络分析任务。 控制器通过计算机网络将与代理相对应的映射表传送给每个代理。 接收地图的每个代理根据收到的maplet配置其对应的网络节点进行网络数据采集,收集的数据处理和处理的数据报告。 接收Maplet的每个代理根据配置​​收集和处理网络数据,并将处理后的数据报告给控制器。 作为网络分析任务的结果,控制器聚合从每个代理报告的数据。

    Order-independent stream query processing
    2.
    发明授权
    Order-independent stream query processing 有权
    与订单无关的流查询处理

    公开(公告)号:US08972446B2

    公开(公告)日:2015-03-03

    申请号:US13936922

    申请日:2013-07-08

    CPC classification number: G06F17/30979 G06F17/30516

    Abstract: In a system and method for order-independent stream query processing, one or more input streams of data are received, and the one or more input streams are analyzed to determine data which is older than an already emitted progress indicator. The data which is older than the already emitted progress indicator is partitioned into one or more partitions, and each of the one or more partitions are independently processed using out-of-order processing techniques. A query is received, rewritten and decomposed into one or more sub-queries that produce partial results for each of the one or more partitions, where each of the one or more sub-queries correspond to a partition. A view is also produced that consolidates the partial results for each partition. The partial results are consolidated at a consolidation time specified by the query to produce final results, and the final results are provided.

    Abstract translation: 在用于与秩序无关的流查询处理的系统和方法中,接收一个或多个输入数据流,并且分析一个或多个输入流以确定比已经发射的进度指示符更早的数据。 比已经发射的进度指示符更老的数据被分割成一个或多个分区,并且使用无序处理技术来独立地处理一个或多个分区中的每一个。 查询被接收,重写并分解成一个或多个子查询,其产生针对一个或多个分区中的每个分区的部分结果,其中一个或多个子查询中的每一个对应于分区。 还会生成一个整合每个分区的部分结果的视图。 部分结果在查询指定的合并时间内合并,以生成最终结果,并提供最终结果。

    Speculative data processing of streaming data
    3.
    发明授权
    Speculative data processing of streaming data 有权
    流数据的投机数据处理

    公开(公告)号:US09438676B2

    公开(公告)日:2016-09-06

    申请号:US14341436

    申请日:2014-07-25

    Abstract: In an embodiment, a method comprises receiving a plurality of source data records from one or more source computers, wherein one or more first source data records are associated with a first source transaction and one or more second source data records are associated with a second source transaction; generating a first derived transaction comprising one or more first derived records based on the plurality of source data records; generating a first transaction mapping between the first derived transaction and the first source transaction; generating a second transaction mapping between the first derived transaction and the second source transaction; determining that the first derived transaction has ended, and in response, committing first derived transaction including the one or more first derived records to a persistent storage; receiving a first ending punctuation associated with the first source transaction, and in response, committing the first source transaction including the one or more first source data records associated with the first source transaction to the persistent storage; after committing the first derived transaction, determining that the second source transaction failed, and in response: determining that the first derived transaction should be regenerated based on the second transaction mapping, and in response, regenerating the first derived transaction.

    Abstract translation: 在一个实施例中,一种方法包括从一个或多个源计算机接收多个源数据记录,其中一个或多个第一源数据记录与第一源事务相关联,并且一个或多个第二源数据记录与第二源 交易; 基于所述多个源数据记录,生成包括一个或多个第一导出记录的第一导出事务; 在所述第一派生事务和所述第一源事务之间生成第一事务映射; 在所述第一派生事务和所述第二源事务之间生成第二事务映射; 确定第一派生交易已经结束,并且作为响应,将包括一个或多个第一派生记录的第一派生交易提交给持久存储器; 接收与所述第一源事务相关联的第一结束标点符号,并且作为响应,将包括与所述第一源事务相关联的所述一个或多个第一源数据记录的所述第一源事务提交给所述持久存储器; 在提交第一派生事务之后,确定第二源事务失败,并作为响应:确定应该基于第二事务映射来重新生成第一派生事务,并作为响应,重新生成第一派生事务。

    DISTRIBUTING AND PROCESSING STREAMS OVER ONE OR MORE NETWORKS
    4.
    发明申请
    DISTRIBUTING AND PROCESSING STREAMS OVER ONE OR MORE NETWORKS 有权
    一个或多个网络的分布和处理流程

    公开(公告)号:US20130275452A1

    公开(公告)日:2013-10-17

    申请号:US13865054

    申请日:2013-04-17

    CPC classification number: G06F17/30445 G06F17/30516

    Abstract: In an embodiment, a method for distributing and processing streams over wide area networks comprises receiving, at a unified data processing node, a continuous query; determining a parallel portion of the continuous query; sending the parallel portion to a plurality of distributed data processing nodes located in a plurality of data centers; at each distributed node in the plurality of distributed nodes, locally executing the parallel portion against independent data partitions, producing a partial summary data, sending the partial summary data to the unified node; continuously receiving, at the unified node, in real-time, the partial summary data.

    Abstract translation: 在一个实施例中,一种用于在广域网上分发和处理流的方法包括在统一数据处理节点处接收连续查询; 确定连续查询的并行部分; 将并行部分发送到位于多个数据中心中的多个分布式数据处理节点; 在多个分布式节点中的每个分布式节点处,针对独立数据分区本地执行并行部分,产生部分摘要数据,将该部分摘要数据发送到统一节点; 在统一节点连续接收实时的部分摘要数据。

    Distributing and processing streams over one or more networks for on-the-fly schema evolution

    公开(公告)号:US11210277B2

    公开(公告)日:2021-12-28

    申请号:US15893948

    申请日:2018-02-12

    Abstract: In an embodiment, a method comprises receiving a first record comprising one or more first fields from a first source computer; in response to determining that the first record is a first type and a first node is associated with the first type, sending the first record to the first node to be processed; receiving a second record comprising the one or more first fields and one or more second fields from a second source computer; in response to determining that the second record is a second type and a second node is associated with the second type, sending the second record to the second node; in response to determining that the second type is a first subtype of the first type, sending the second record to the first node to be processed, without suspending the first node.

    Distributed and adaptive computer network analytics

    公开(公告)号:US10305759B2

    公开(公告)日:2019-05-28

    申请号:US14589953

    申请日:2015-01-05

    Abstract: A network analytics controller in a computer network receives specification of a network analysis task. The controller creates maplets. Each maplet corresponds to an agent executing on a network node in the computer network. Each maplet specifies the network data collection configuration, collected data processing, and processed data reporting to be performed to support the network analysis task at the node executing the corresponding agent. The controller communicates the maplet corresponding to the agent over the computer network to each agent. Each agent receiving a maplet configures its corresponding network node for network data collection, collected data processing, and processed data reporting in accordance with the received maplet. Each agent receiving a maplet collects and processes network data, and reports the processed data to the controller, in accordance with the configuration. The controller aggregates, as the result of the network analysis task, the data reported from each agent.

    Integrating rule based systems with distributed data processing by pushing control to edge agents

    公开(公告)号:US09727819B2

    公开(公告)日:2017-08-08

    申请号:US14563111

    申请日:2014-12-08

    CPC classification number: G06N5/025 G06F17/30395 G06F17/30557

    Abstract: In an embodiment, an improved computer-implemented method of efficiently determining actions to perform based on data from a streaming continuous queries in a distributed computer system comprises, at a central control computer, receiving a streaming continuous query and a rule-set; wherein the rule-set comprises decision data representing decisions based on attributes produced by the query, and action data representing end actions based on the decisions, wherein the attributes comprise data processed by one or more networked computers; separating the streaming continuous query into a sub-query executable at one or more edge computers; categorizing end actions from the set based on decisions requiring attributes available from the sub-query into a set of one or more edge expressions that are configured to be evaluated at an edge agent to cause an action; providing the set of edge expressions and the sub-query to at least one edge computer with instructions to process visible attributes on the edge computer and to evaluate the set of one or more edge expressions independently from the central control computer; wherein the method is performed by one or more computing devices.

Patent Agency Ranking