公开(公告)号：US09239864B2

公开(公告)日：2016-01-19

申请号：US13865054

申请日：2013-04-17

Applicant: Cisco Technology, Inc.

Inventor： Saileshwar Krishnamurthy ,  Madhu Kumar ,  Amit Bhat ,  Maciek Sakrejda ,  Robert Allen Lerche

IPC: G06F17/30

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

公开(公告)号：US20150112767A1

公开(公告)日：2015-04-23

申请号：US14056514

申请日：2013-10-17

Applicant: CISCO TECHNOLOGY, INC.

Inventor： Kevin D. Shatzkamer ,  Saileshwar Krishnamurthy ,  David A. Maluf ,  Sateesh K. Addepalli

IPC: G06Q30/02

CPC classification number: G06Q30/0205

Abstract: An example method is provided in one example embodiment and includes receiving a mobility event message for a first user equipment; determining demographic information for a first subscriber associated with the first user equipment; determining a location of the first subscriber in relation to a first network domain; identifying one or more advertising domains in relation to the location of the first subscriber based on the first network domain; determining a modeling function based on the mobility event message and the location of the first subscriber in relation to the identified advertising domains; updating, based on the modeling function, one or more demographic models for each of the identified one or more advertising domains using the demographic information for the first subscriber; and following the updating, calculating demographic information for all subscribers for each of the updated one or more demographic models for the identified advertising domains.

Abstract translation: 在一个示例实施例中提供了示例性方法，并且包括接收用于第一用户设备的移动性事件消息; 确定与所述第一用户设备相关联的第一用户的人口统计信息; 确定第一用户相对于第一网络域的位置; 基于所述第一网络域识别关于所述第一订户的位置的一个或多个广告域; 基于所述移动性事件消息和所述第一订户相对于所识别的广告域的位置来确定建模功能; 基于所述建模功能，使用所述第一用户的人口统计信息更新所识别的一个或多个广告域中的每一个的一个或多个人口统计模型; 并且在所述更新之后，针对所识别的广告域的每个更新的一个或多个人口统计模型来计算所有订户的人口统计信息。

公开(公告)号：US20140012877A1

公开(公告)日：2014-01-09

申请号：US13936922

申请日：2013-07-08

Applicant: Cisco Technology, Inc.

Inventor： Saileshwar Krishnamurthy ,  Michael R. Lewis ,  Wing Li ,  Neil Thombre ,  Jeffrey A. Davis ,  Daniel Robert Farina

IPC: G06F17/30

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

公开(公告)号：US20250062975A1

公开(公告)日：2025-02-20

申请号：US18935088

申请日：2024-11-01

Applicant: Cisco Technology, Inc.

Inventor： Ludwig Alexander Clemm ,  Yegnanarayanan Chandramouli ,  Saileshwar Krishnamurthy ,  Shashidhar Srinivasa ,  Wojciech Dec ,  Ashwin Pankaj

IPC: H04L43/04 ,  H04L41/046 ,  H04L41/0803 ,  H04L41/14 ,  H04L67/10

Abstract: A network analytics controller is established in a network. The network includes a plurality of nodes. A plurality of network analytics agents is established; each agent at a node of the network. Network analytics configuration parameters, including a network analytics scope, are received at the networks analytics controller. A task is assigned to each agent at a node determined to be within the network analytics scope, the task comprising that portion of the network analytics specified in the network analytics configuration parameters relevant to the corresponding node. The assigned task is performed at each agent assigned a task. The networks analytics controller receives the results of each performed task, and aggregates the received results.

公开(公告)号：US20180165313A1

公开(公告)日：2018-06-14

申请号：US15893948

申请日：2018-02-12

Applicant: Cisco Technology, Inc.

Inventor： Saileshwar Krishnamurthy

IPC: G06F17/30 ,  H04L29/08 ,  G06F9/50

CPC classification number: G06F16/2228 ,  G06F9/50 ,  G06F16/24568 ,  H04L67/10

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.

公开(公告)号：US09959301B2

公开(公告)日：2018-05-01

申请号：US14341676

申请日：2014-07-25

Applicant: Cisco Technology, Inc.

Inventor： Saileshwar Krishnamurthy

IPC: G06F17/30 ,  G06F9/50 ,  H04L29/08

CPC classification number: G06F17/30321 ,  G06F9/50 ,  G06F17/30516 ,  H04L67/10

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.

公开(公告)号：US20160162787A1

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

申请号：US14563111

申请日：2014-12-08

Applicant: Cisco Technology, Inc.

Inventor： Vikram Kumaran ,  Saileshwar Krishnamurthy

IPC: G06N5/02 ,  G06F17/30

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.

Abstract translation: 在一个实施例中，一种改进的计算机实现的方法，其有效地确定基于来自分布式计算机系统中的流式连续查询的数据来执行的动作，包括在中央控制计算机处接收流连续查询和规则集; 其中所述规则集包括基于由所述查询产生的属性来表示决策的决策数据，以及基于所述决定表示结束动作的动作数据，其中所述属性包括由一个或多个联网计算机处理的数据; 将流连续查询分离成一个或多个边缘计算机的子查询可执行文件; 根据需要从子查询可用的属性的决策将结束动作分类成一组一个或多个边缘表达，其被配置为在边缘代理处进行评估以引起动作; 将至少一个边缘计算机的边缘表达式和子查询集合提供给处理边缘计算机上的可见属性的指令，并且独立于中央控制计算机来评估一个或多个边缘表达的集合; 其中所述方法由一个或多个计算设备执行。

公开(公告)号：US20160094420A1

公开(公告)日：2016-03-31

申请号：US14550885

申请日：2014-11-21

Applicant: Cisco Technology, Inc.

Inventor： Ludwig Alexander Clemm ,  Yegnanarayanan Chandramouli ,  Saileshwar Krishnamurthy ,  Shashidhar Srinivasa

IPC: H04L12/26 ,  H04L29/08

CPC classification number: H04L43/04 ,  H04L41/046 ,  H04L41/0803 ,  H04L41/145 ,  H04L67/10

Abstract: A network analytics controller is established in a network. The network includes a plurality of nodes. A plurality of network analytics agents is established; each agent at a node of the network. Network analytics configuration parameters, including a network analytics scope, are received at the networks analytics controller. A task is assigned to each agent at a node determined to be within the network analytics scope, the task comprising that portion of the network analytics specified in the network analytics configuration parameters relevant to the corresponding node. The assigned task is performed at each agent assigned a task. The networks analytics controller receives the results of each performed task, and aggregates the received results.

Abstract translation: 在网络中建立网络分析控制器。 网络包括多个节点。 建立了多个网络分析代理; 每个代理在网络的一个节点。 在网络分析控制器处收到网络分析配置参数，包括网络分析范围。 任务被分配给确定在网络分析范围内的节点处的每个代理，该任务包括在与相应节点相关的网络分析配置参数中指定的网络分析部分。 在分配任务的每个代理处执行分配的任务。 网络分析控制器接收每个执行任务的结果，并聚合接收的结果。