公开(公告)号：US20140237477A1

公开(公告)日：2014-08-21

申请号：US14261090

申请日：2014-04-24

Applicant: NEC Laboratories America, Inc.

Inventor： Srihari Cadambi ,  Kunal Rao ,  Srimat Chakradhar ,  Rajat Phull ,  Giuseppe Coviello ,  Murugan Sankaradass ,  Cheng-Hong Li

IPC: G06F9/46

CPC classification number: G06F9/5044 ,  G06F9/4881

Abstract: Methods and systems for scheduling jobs to manycore nodes in a cluster include selecting a job to run according to the job's wait time and the job's expected execution time; sending job requirements to all nodes in a cluster, where each node includes a manycore processor; determining at each node whether said node has sufficient resources to ever satisfy the job requirements and, if no node has sufficient resources, deleting the job; creating a list of nodes that have sufficient free resources at a present time to satisfy the job requirements; and assigning the job to a node, based on a difference between an expected execution time and associated confidence value for each node and a hypothetical fastest execution time and associated hypothetical maximum confidence value.

Abstract translation: 将作业调度到群集节点的方法和系统包括根据作业的等待时间和作业的预期执行时间来选择要运行的作业; 向群集中的所有节点发送作业需求，其中每个节点包括一个处理器; 在每个节点处确定所述节点是否具有足够的资源以满足工作要求，如果没有节点具有足够的资源，则删除该作业; 创建一个目前有足够空闲资源的节点列表，以满足工作要求; 并且基于每个节点的预期执行时间和相关联的置信度值之间的差异以及假设的最快执行时间和相关联的假设最大置信度值将作业分配给节点。

公开(公告)号：US20240394110A1

公开(公告)日：2024-11-28

申请号：US18672464

申请日：2024-05-23

Applicant: NEC Laboratories America, Inc.

Inventor： Giuseppe Coviello ,  Priscilla Benedetti ,  Kunal G. Rao ,  Srimat Chakradhar

IPC: G06F9/50 ,  G06F11/34

Abstract: Systems and methods are provided for dynamically adjusting computing resources allocated to tasks within a stream processing application, including initiating monitoring of application-specific characteristics for each task, the characteristics including processor (CPU) usage and processing time, assessing resource allocation needs for each task based on the monitored characteristics to determine discrepancies between current resource allocation and optimal performance requirements, and implementing exploratory resource adjustments by incrementally modifying CPU resources allocated to a subset of tasks and analyzing an impact of the exploratory resource adjustments on task performance metrics. Optimal resource allocations are determined for each task using a regression model that incorporates historical and real-time performance data, and the optimal resource allocations are applied to the tasks to minimize processing time and maximize resource use efficiency. The optimal resource allocations are iteratively updated in response to changes in task characteristics or application demands.

公开(公告)号：US12047467B2

公开(公告)日：2024-07-23

申请号：US18321880

申请日：2023-05-23

Applicant: NEC Laboratories America, Inc.

Inventor： Giuseppe Coviello ,  Kunal Rao ,  Srimat Chakradhar

IPC: H04L67/55 ,  H04L67/563

CPC classification number: H04L67/55 ,  H04L67/563

Abstract: A pull-based communication method for microservices-based real-time streaming video analytics pipelines is provided. The method includes receiving a plurality of frames from a plurality of cameras, each camera including a camera sidecar, arranging a plurality of detectors in layers such that a first detector layer includes detectors with detector sidecars and detector business logic, and the second detector layer includes detectors with only sidecars, arranging a plurality of extractors in layers such that a first extractor layer includes extractors with extractor sidecars and extractor business logic, and the second extractor layer includes extractors with only sidecars, and enabling a mesh controller, during registration, to selectively assign inputs to one or more of the detector sidecars of the first detector layer and one or more of the extractor sidecars of the first extractor layer to pull data items for processing.

公开(公告)号：US20240118938A1

公开(公告)日：2024-04-11

申请号：US18474658

申请日：2023-09-26

Applicant: NEC Laboratories America, Inc.

Inventor： Giuseppe Coviello ,  Kunal Rao ,  Srimat Chakradhar ,  Priscilla Benedetti

IPC: G06F9/50

CPC classification number: G06F9/5055

Abstract: A computer implemented method is provided for resource management of stream analytics at each individual node that includes computing a mean of output processing rate of microservices in a pipeline; and evaluating a state of each microservice of the microservices in the pipeline. The computer implemented method also includes selecting a single microservice from the pipeline for updating resources for an action that changes the state in single the microservice that is selected; and performing resource allocation update for the selected microservice. The computer implemented method may also include updating the state of the selected microservice.

公开(公告)号：US11810398B2

公开(公告)日：2023-11-07

申请号：US17526492

申请日：2021-11-15

Applicant: NEC Laboratories America, Inc.

Inventor： Biplob Debnath ,  Srimat Chakradhar ,  Giuseppe Coviello ,  Yi Yang

IPC: G06V40/16 ,  G06V10/75 ,  G06F18/10 ,  G06F18/2321

CPC classification number: G06V40/172 ,  G06F18/10 ,  G06F18/2321 ,  G06V10/751

Abstract: Methods and systems for face clustering include determining a quality score for each of a set of input images. A first subset of the input images is clustered, having respective quality scores that exceed a predetermined threshold, to form an initial set of clusters. A second subset of the input images is clustered, having respective quality scores below the predetermined threshold. An action is performed responsive to the clustered images after the second subset is added to the initial set of clusters.

公开(公告)号：US11132223B2

公开(公告)日：2021-09-28

申请号：US16809192

申请日：2020-03-04

Applicant: NEC Laboratories America, Inc.

Inventor： Kunal Rao ,  Yi Yang ,  Srimat Chakradhar ,  Giuseppe Coviello ,  Min Feng ,  Murugan Sankaradas

IPC: G06F9/46 ,  G06F9/48 ,  G06F9/50 ,  G06F9/30 ,  G06F9/4401

Abstract: A computer-implemented method includes obtaining a usecase specification and a usecase runtime specification corresponding to the usecase. The usecase includes a plurality of applications each being associated with a micro-service providing a corresponding functionality within the usecase for performing a task. The method further includes managing execution of the usecase within a runtime system based on the usecase and usecase runtime specifications to perform the task by serving an on-demand query and dynamically scaling resources based on the on-demand query, including using a batch helper server to employ the usecase specification to load dynamic application instances and connect the dynamic application instances to existing instances, and employ a batch helper configuration to load nodes/machines for execution of the on-demand query.

公开(公告)号：US20200293759A1

公开(公告)日：2020-09-17

申请号：US16814453

申请日：2020-03-10

Applicant: NEC Laboratories America, Inc.

Inventor： Biplob Debnath ,  Giuseppe Coviello ,  Srimat Chakradhar ,  Debayan Deb

IPC: G06K9/00 ,  G06K9/62

Abstract: Methods and systems for image clustering include matching a new image to a representative image of a cluster. The new image is set as a representative of the cluster with a first time limit. The new image is set as a representative of the cluster with a second time limit, responsive to a determination that the new image has matched at least one incoming image during the first time limit.

公开(公告)号：US20200293371A1

公开(公告)日：2020-09-17

申请号：US16809154

申请日：2020-03-04

Applicant: NEC Laboratories America, Inc.

Inventor： Yi Yang ,  Kunal Rao ,  Srimat Chakradhar ,  Giuseppe Coviello ,  Min Feng ,  Murugan Sankaradas

IPC: G06F9/48 ,  G06F9/46

Abstract: A computer-implemented method includes obtaining a usecase specification and a usecase runtime specification corresponding to the usecase. The usecase includes a plurality of applications each being associated with a micro-service providing a corresponding functionality within the usecase for performing a task. The method further includes determining that at least one instance of the at least one of the plurality of applications can be reused during execution of the usecase based on the usecase specification and the usecase runtime specification, and reusing the at least one instance during execution of the usecase.

公开(公告)号：US20160110404A1

公开(公告)日：2016-04-21

申请号：US14831775

申请日：2015-08-20

Applicant: NEC LABORATORIES AMERICA, INC.

Inventor： Kunal Rao ,  Giuseppe Coviello ,  Srimat Chakradhar ,  Souvik Bhattacherjee ,  Srihari Cadambi

IPC: G06F17/30

CPC classification number: G06F3/0638 ,  G06F3/0604 ,  G06F3/0619 ,  G06F3/067 ,  G06F17/30368 ,  G06F17/30371 ,  G06F17/30374 ,  G06F17/30424 ,  G06F17/30867 ,  G06F17/30876 ,  G06F17/30958 ,  G06T11/206

Abstract: A method is provided for detecting abnormal changes in real-time in dynamic graphs. The method includes extracting, by a graph sampler, an active sampled graph from an underlying base graph. The method further includes merging, by a graph merger, the active sampled graph with graph updates within a predetermined recent time period to generate a merged graph. The method also includes computing, by a graph diameter computer, a diameter of the merged graph. The method additionally includes determining, by a graph diameter change determination device, whether a graph diameter change exists. The method further includes generating, by an alarm generator, a user-perceptible alarm responsive to the graph diameter change.

Abstract translation: 提供了一种用于在动态图中实时检测异常变化的方法。 该方法包括通过图形采样器从底层基础图提取活动采样图。 该方法还包括通过图形合并将活动采样图与预定的最近时间段内的图更新进行合并，以生成合并图。 该方法还包括通过图形直径计算机计算合并图的直径。 该方法还包括通过图形直径变化确定装置确定是否存在图形直径变化。 该方法还包括响应于图形直径变化，通过报警发生器生成用户可感知的报警。

公开(公告)号：US20160110134A1

公开(公告)日：2016-04-21

申请号：US14831792

申请日：2015-08-20

Applicant: NEC Laboratories America, Inc.

Inventor： Kunal Rao ,  Giuseppe Coviello ,  Srimat Chakradhar ,  Souvik Bhattacherjee ,  Srihari Cadambi

IPC: G06F3/06

CPC classification number: G06F3/0638 ,  G06F3/0604 ,  G06F3/0619 ,  G06F3/067 ,  G06F17/30368 ,  G06F17/30371 ,  G06F17/30374 ,  G06F17/30424 ,  G06F17/30867 ,  G06F17/30876 ,  G06F17/30958 ,  G06T11/206

Abstract: A graph storage and processing system is provided. The system includes a scalable, distributed, fault-tolerant, in-memory graph storage device for storing base graph data representative of graphs. The system further includes a real-time, in memory graph storage device for storing update graph data representative of graph updates for the graphs with respect to a time threshold. The system also includes an in-memory graph sampler for sampling the base graph data to generate sampled portions of the graphs and for storing the sampled portions of the graph. The system additionally includes a query manager for providing a query interface between applications and the system and for forming graph data representative of a complete graph from at least the base graph data and the update graph data, if any. The system also includes a graph computer for processing the sampled portions using batch-type computations to generate approximate results for graph-based queries.

Abstract translation: 提供图形存储和处理系统。 该系统包括可扩展的，分布式的，容错的存储器内存图形存储装置，用于存储表示图形的基本图形数据。 该系统还包括一个实时存储器图形存储装置，用于存储代表图形关于时间阈值的图形更新的更新图形数据。 该系统还包括存储器内图形采样器，用于对基本图形数据进行采样以生成图形的采样部分并存储图形的采样部分。 该系统还包括查询管理器，用于在应用和系统之间提供查询接口，并且用于从至少基本图形数据和更新图形数据（如果有的话）形成表示完整图形的图形数据。 该系统还包括用于使用分批式计算来处理采样部分以生成基于图的查询的近似结果的图形计算机。