公开(公告)号：US20160162543A1

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

申请号：US14733693

申请日：2015-06-08

Applicant: General Electric Company

Inventor： Steven Matt Gustafson ,  Abha Moitra ,  Kareem Sherif Aggour ,  Luis Babaji Ng Tari ,  Aisha Yousuf

IPC: G06F17/30

CPC classification number: G06F17/30448 ,  G06F17/30353 ,  G06F17/30477 ,  G06F17/30548 ,  G06Q50/00

Abstract: A system and method for searching for and finding data across industrial time-series data is disclosed. A computer system receives a search query from a client system. The computer system accesses a database including a plurality of stored time-series data sets. For each stored time-series data set, the computer system determines whether the stored time-series data set includes one or more sections that match the received search query. In accordance with a determination that two or more of stored time-series data sets include at least one section that matches the received search query, the computer system determines whether the matching sections in each stored time-series data set have overlapping time periods. In accordance with a determination that the matching sections in each time-series data set have overlapping time periods, the computer system identifies a particular event that occurred during the overlapping time periods.

Abstract translation: 公开了一种用于在工业时间序列数据中搜索和查找数据的系统和方法。 计算机系统从客户端系统接收搜索查询。 计算机系统访问包括多个存储的时间序列数据集的数据库。 对于每个存储的时间序列数据集，计算机系统确定所存储的时间序列数据集是否包括与所接收的搜索查询匹配的一个或多个部分。 根据存储的时间序列数据集中的两个或更多个包括与所接收的搜索查询匹配的至少一个部分的确定，计算机系统确定每个存储的时间序列数据集中的匹配部分是否具有重叠的时间段。 根据每个时间序列数据集中的匹配部分具有重叠时间段的确定，计算机系统识别在重叠时间段期间发生的特定事件。

公开(公告)号：US20160121483A1

公开(公告)日：2016-05-05

申请号：US14530399

申请日：2014-10-31

Applicant: General Electric Company

Inventor： Justin McHugh, IV ,  Kareem Sherif Aggour ,  John Michael Lizzi ,  Charles Burton Theurer

IPC: B25J9/16 ,  B25J9/00

CPC classification number: B25J9/163 ,  G05B2219/39146 ,  G05B2219/40323

Abstract: A method, system, and non-transitory computer-readable medium, the method including receiving notifications from a plurality of agents, the notifications being associated with the plurality of agents sensing aspects of an environment; determining, based at least in part on the received notifications from the plurality of agents, a situational model of the environment from the notifications; determining a status of the environment based on the situational model; and reporting the status of the environment to at least one of the plurality of agents.

Abstract translation: 一种方法，系统和非暂时性计算机可读介质，所述方法包括从多个代理接收通知，所述通知与感测环境方面的所述多个代理相关联; 至少部分地基于所接收的来自所述多个代理的通知，从所述通知中确定所述环境的情境模型; 基于情境模型确定环境状况; 以及将所述环境的状态报告给所述多个代理中的至少一个。

公开(公告)号：US20160110478A1

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

申请号：US14517485

申请日：2014-10-17

Applicant: General Electric Company

Inventor： Kareem Sherif Aggour ,  Andrew Walter Crapo ,  Abha Moitra ,  Steven Matt Gustafson

IPC: G06F17/30 ,  G06F11/30 ,  G06F11/34

CPC classification number: G06F16/904 ,  G06F17/40

Abstract: Embodiments allow blocking and featurization of time-series data gathered from at least one sensor. The input time-series data is divided into blocks with common attributes (features) according to feature models that describe patterns in the data. The blocks may be overlapping or non-overlapping. The resultant feature blocks are annotated with feature information and semantic meaning. The feature blocks can be indexed to facilitate semantic search of the data. Feature blocks may be further analyzed to create semantic blocks that incorporate semantic meaning and features for multiple feature blocks, sensors and/or related time-series data. The semantic blocks can also be indexed to facilitate semantic search of the data.

Abstract translation: 实施例允许从至少一个传感器收集的时间序列数据的阻塞和特征化。 根据描述数据中的模式的特征模型，输入时间序列数据被划分为具有共同属性（特征）的块。 块可以是重叠的或不重叠的。 所得到的特征块用特征信息和语义来注释。 特征块可以索引，以便于数据的语义搜索。 可以进一步分析特征块以创建包含多个特征块，传感器和/或相关时间序列数据的语义和特征的语义块。 语义块也可以索引，以便于数据的语义搜索。

公开(公告)号：US20160019091A1

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

申请号：US14335315

申请日：2014-07-18

Applicant: General Electric Company

Inventor： Christina Ann Leber ,  John A. Interrante ,  Kareem Sherif Aggour ,  Jenny Marie Weisenberg Williams

IPC: G06F9/48 ,  G06F9/50

CPC classification number: G06F11/34 ,  G06F9/46 ,  G06F11/00 ,  G06F11/1466

Abstract: A system includes a processor and a non-transitory computer-readable medium. The non-transitory computer-readable medium comprises instructions executable by the processor to cause the system to perform a method. The method comprises receiving a first job to execute and executing the first job. A plurality of data associated with the first job is determined The plurality of data comprises data associated with (i) a second job executed immediately prior to the first job, (ii) a third job executed immediately after the first job, (iii) a determination of whether the first job failed or executed successfully and (iv) a type of data associated with the first job. The determined plurality of data is stored.

Abstract translation: 系统包括处理器和非暂时计算机可读介质。 非暂时性计算机可读介质包括可由处理器执行以使系统执行方法的指令。 该方法包括接收第一作业以执行和执行第一作业。 确定与第一作业相关联的多个数据。多个数据包括与（i）在第一作业之前执行的第二作业相关联的数据，（ii）紧接在第一作业之后执行的第三作业，（iii） 确定第一个作业是否失败或成功执行;以及（iv）与第一个作业相关联的一种数据。 存储确定的多个数据。

公开(公告)号：US09087098B2

公开(公告)日：2015-07-21

申请号：US13716567

申请日：2012-12-17

Applicant: General Electric Company

Inventor： Jerry Lin ,  Kareem Sherif Aggour ,  Brian Scott Courtney ,  John Alan Interrante ,  Christina Ann LaComb ,  Sunil Mathur ,  Christopher Thomas McConnell ,  Quinn Snell

IPC: G06F17/30

CPC classification number: G06F17/30424 ,  G06F17/30545 ,  G06F17/30584

Abstract: A service for storing time series data provides a data pipe for receiving time series data, a query pipe for making requests to the service, and a result pipe for receiving output from the service. Data sent to the query pipe is processed by an ingester that prepares metadata indices associated with blocks of incoming time series data and stores the blocks of data in a time series database and the indices in a separate index database. A query layer receives queries from the query pipe and uses the index database to determine which data blocks are needed to process the query, and then requests only those data blocks from the time series database. Processing of the query is performed within the time series database only on those data nodes that contain relevant data, and partial results are passed to an output layer for formation into a final query result which is sent out by the results pipe.

Abstract translation: 用于存储时间序列数据的服务提供用于接收时间序列数据的数据管道，用于对服务进行请求的查询管道以及用于从服务接收输出的结果管道。 发送到查询管道的数据由一个准备与输入时间序列数据块相关联的元数据索引并且将数据块存储在时间序列数据库中的索引进行处理，并将索引存储在单独的索引数据库中。 查询层从查询管道接收查询，并使用索引数据库来确定处理查询需要哪些数据块，然后仅从时间序列数据库中请求那些数据块。 在时间序列数据库中仅在包含相关数据的那些数据节点上执行查询的处理，并将部分结果传递到输出层以形成结果管道发送的最终查询结果。

公开(公告)号：US10046457B2

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

申请号：US14530399

申请日：2014-10-31

Applicant: General Electric Company

Inventor： Justin McHugh ,  Kareem Sherif Aggour ,  John Michael Lizzi ,  Charles Burton Theurer

IPC: G05B19/418 ,  B25J9/16

Abstract: A method, system, and non-transitory computer-readable medium, the method including receiving notifications from a plurality of agents, the notifications being associated with the plurality of agents sensing aspects of an environment; determining, based at least in part on the received notifications from the plurality of agents, a situational model of the environment from the notifications; determining a status of the environment based on the situational model; and reporting the status of the environment to at least one of the plurality of agents.

公开(公告)号：US20150356154A1

公开(公告)日：2015-12-10

申请号：US14826807

申请日：2015-08-14

Applicant: General Electric Company

Inventor： Jerry Lin ,  Kareem Sherif Aggour ,  Brian Scott Courtney ,  John Alan Interrante ,  Christina Ann LaComb ,  Sunil Mathur ,  Christopher Thomas McConnell ,  Quinn Snell

IPC: G06F17/30

CPC classification number: G06F17/30551 ,  G06F17/30336 ,  G06F17/30424 ,  G06F17/30477 ,  G06F17/30545 ,  G06F17/30584

Abstract: A system for storing time series data includes an ingester that prepares metadata indices associated with blocks of incoming time series data and stores the blocks of data in a time series database and the indices in a separate index database. The time series database distributes storage of the data blocks among multiple data nodes. A query layer receives queries and uses the index database to determine which data blocks are needed to process the query, and then requests only those data blocks from the time series database. Processing of the query is performed within the time series database only on those data nodes that contain relevant data, and partial results are passed to an output layer for formation into a final query result.

Abstract translation: 用于存储时间序列数据的系统包括准备与输入的时间序列数据的块相关联的元数据索引并且将数据块存储在时间序列数据库中并且索引存储在单独的索引数据库中的创建器。 时间序列数据库在多个数据节点之间分配数据块的存储。 查询层接收查询并使用索引数据库来确定处理查询需要哪些数据块，然后仅从时间序列数据库中请求那些数据块。 查询的处理仅在时间序列数据库中仅在包含相关数据的那些数据节点上执行，部分结果将传递到输出层以形成最终查询结果。

公开(公告)号：US09152672B2

公开(公告)日：2015-10-06

申请号：US13716560

申请日：2012-12-17

Applicant: General Electric Company

Inventor： Jerry Lin ,  Kareem Sherif Aggour ,  Brian Scott Courtney ,  John Alan Interrante ,  Christina Ann LaComb ,  Sunil Mathur ,  Christopher Thomas McConnell ,  Quinn Snell

IPC: G06F17/30

CPC classification number: G06F17/30477 ,  G06F17/30336 ,  G06F17/30424 ,  G06F17/30545 ,  G06F17/30584

Abstract: A method for performing queries on a distributed time series data storage system is presented. The time series data storage system has a time series database that stores data blocks containing time stamped data across a plurality of computing devices. The system also includes an index database that stores an index associated with the time stamped data in each data block. The method includes the steps of sending a query, requesting indices, returning the indices, preparing a sub-query, forwarding the sub-query to an evaluator, evaluating the sub-query, performing a logical operation on each sub-query's result, receiving the sub-results at an output handler, and combining the sub-results.

Abstract translation: 提出了一种在分布式时间序列数据存储系统上执行查询的方法。 时间序列数据存储系统具有时间序列数据库，其存储跨越多个计算装置的包含时间戳数据的数据块。 该系统还包括索引数据库，其存储与每个数据块中的时间戳数据相关联的索引。 该方法包括以下步骤：发送查询，请求索引，返回索引，准备子查询，将子查询转发给评估者，评估子查询，对每个子查询的结果执行逻辑运算，接收 在输出处理程序中的子结果，并组合子结果。

公开(公告)号：US20140172866A1

公开(公告)日：2014-06-19

申请号：US13716554

申请日：2012-12-17

Applicant: GENERAL ELECTRIC COMPANY

Inventor： Jerry Lin ,  Kareem Sherif Aggour ,  Brian Scott Courtney ,  John Alan Interrante ,  Christina Ann LaComb ,  Sunil Mathur ,  Christopher Thomas McConnell ,  Quinn Snell

IPC: G06F17/30

CPC classification number: G06F17/30551 ,  G06F17/30336 ,  G06F17/30424 ,  G06F17/30477 ,  G06F17/30545 ,  G06F17/30584

Abstract: A system for storing time series data includes an ingester that prepares metadata indices associated with blocks of incoming time series data and stores the blocks of data in a time series database and the indices in a separate index database. The time series database distributes storage of the data blocks among multiple data nodes. A query layer receives queries and uses the index database to determine which data blocks are needed to process the query, and then requests only those data blocks from the time series database. Processing of the query is performed within the time series database only on those data nodes that contain relevant data, and partial results are passed to an output layer for formation into a final query result.

Abstract translation: 用于存储时间序列数据的系统包括准备与输入的时间序列数据的块相关联的元数据索引并且将数据块存储在时间序列数据库中并且索引存储在单独的索引数据库中的创建器。 时间序列数据库在多个数据节点之间分配数据块的存储。 查询层接收查询并使用索引数据库来确定处理查询需要哪些数据块，然后仅从时间序列数据库中请求那些数据块。 查询的处理仅在时间序列数据库中仅在包含相关数据的那些数据节点上执行，部分结果将传递到输出层以形成最终查询结果。

公开(公告)号：US11216477B2

公开(公告)日：2022-01-04

申请号：US16748044

申请日：2020-01-21

Applicant: General Electric Company

Inventor： Paul Edward Cuddihy ,  Jenny Marie Weisenberg Williams ,  Kareem Sherif Aggour ,  Vijay S Kumar ,  Varish Mulwad

IPC: G06F16/30 ,  G06F16/2458 ,  G06F16/242 ,  G06F16/2453 ,  G06F16/955 ,  G06F16/22

Abstract: According to some embodiments, a system, method and non-transitory computer-readable medium are provided comprising receiving a node group at an integration module, wherein the node group includes one or more requests for internal data and external data, wherein internal data is data stored in an internal datastore and external data is data stored outside of the internal data store; identifying in a configuration data, one or more meta-data nodes from the node group, wherein each meta-data node indicates a request for external data; retrieving the internal data via execution of an internal data query; determining an order of execution for the one or more meta-data nodes; executing a first meta-data node based on the determined order to generate a first result; ingesting the first result into a semantic datastore; and executing a query to generate a final result, wherein the query includes the retrieved internal data and the ingested first result. Numerous other aspects are provided.