公开(公告)号：US10530661B2

公开(公告)日：2020-01-07

申请号：US15198575

申请日：2016-06-30

Applicant: AT&T Intellectual Property I, L.P.

Inventor： Yaron Kanza ,  Theodore Johnson ,  Vladislav Shkapenyuk ,  Laks V. S. Lakshmanan

IPC: G06F15/173 ,  H04L12/24 ,  G06F16/901 ,  H04W24/04

Abstract: A system may include a processor, an input, and memory comprising a graph database and executable instructions. The executable instructions may cause the processor to effectuate operations. The operations may include receiving, via the input, a query comprising pathway variables. The operations may also include determining an anchor set based on at least one of the pathway variables and identifying an evaluation order based on the anchor set. The operations may also include translating the pathway variables into a pathway algebraic expression based on the evaluation order. The operations may include executing the pathway algebraic expression on the graph database to return a pathway set.

公开(公告)号：US10459922B2

公开(公告)日：2019-10-29

申请号：US15345878

申请日：2016-11-08

Applicant: AT&T Intellectual Property I, L.P.

Inventor： Theodore Johnson ,  Vladislav Shkapenyuk

IPC: H04L9/06 ,  G06F16/2455

Abstract: A device, method and computer-readable medium for generating unique identification for records in a data streaming processing system are disclosed. A method may collect an identification of a source of a data record, a timestamp of the data record and a count of a number of records a data source has added to the stream with that timestamp, generate a unique identification with the identification of the source of the data record, the timestamp of the data record and the count of the number of records the data source has added to the stream with that timestamp, apply the unique identification to the data record and transmit the data record with the unique identification to a downstream operator within a data stream processing system.

公开(公告)号：US10459910B2

公开(公告)日：2019-10-29

申请号：US14996345

申请日：2016-01-15

Applicant: AT&T Intellectual Property I, L.P.

Inventor： Theodore Johnson ,  Lukasz Golab

IPC: G06F16/23 ,  G06F16/25 ,  G06F16/28 ,  G06F16/2455

Abstract: Methods, systems, and products characterize consistency of data in a stream warehouse. A warehouse table is derived from a continuously received a stream of data. The warehouse table is stored in memory as a plurality of temporal partitions, with each temporal partition storing data within a contiguous range of time. A level of consistency is assigned to each temporal partition in the warehouse table.

公开(公告)号：US20180060396A1

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

申请号：US15253591

申请日：2016-08-31

Applicant: AT&T Intellectual Property, I, L.P.

Inventor： Theodore Johnson ,  Vladislav Shkapenyuk ,  Yaron Kanza

IPC: G06F17/30

CPC classification number: G06F17/30958

Abstract: A method includes parsing a regular pathway expression into fragments including an anchored fragment and at least one other fragment. A number of the fragments is based on at least a length limitation of the regular pathway expression. The method includes generating an operator directed acyclic graph (DAG) including non-operator nodes, operator nodes, and a root based on at least the anchored fragment. The method includes removing, from the operator DAG, at least one of the non-operator nodes and connecting a first operator node to a second operator node of the operator nodes. The first operator node includes an edge into the at least one removed non-operator node, and the second operator node includes an edge from the at least one removed node. The method includes executing the operator DAG on a graph database to return a pathway set comprising at least one pathway that satisfies the regular pathway expression.

公开(公告)号：US20180006898A1

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

申请号：US15198575

申请日：2016-06-30

Applicant: AT&T Intellectual Property I, L.P.

Inventor： Yaron Kanza ,  Theodore Johnson ,  Vladislav Shkapenyuk ,  Laks V.S. Lakshmanan

IPC: H04L12/24 ,  G06F17/30

CPC classification number: H04L41/145 ,  G06F16/9024 ,  H04L41/142 ,  H04W24/04

Abstract: A system may include a processor, an input, and memory comprising a graph database and executable instructions. The executable instructions may cause the processor to effectuate operations. The operations may include receiving, via the input, a query comprising pathway variables. The operations may also include determining an anchor set based on at least one of the pathway variables and identifying an evaluation order based on the anchor set. The operations may also include translating the pathway variables into a pathway algebraic expression based on the evaluation order. The operations may include executing the pathway algebraic expression on the graph database to return a pathway set.

公开(公告)号：US09600526B2

公开(公告)日：2017-03-21

申请号：US13706893

申请日：2012-12-06

Applicant: AT&T Intellectual Property I, L.P.

Inventor： Theodore Johnson ,  Marios Hadjieleftheriou ,  Vladislav Shkapenyuk

IPC: G06F17/30

CPC classification number: G06F17/30501 ,  G06F17/30377

Abstract: Concepts and technologies are disclosed herein for generating and using temporal data partition revisions. In some embodiments, a server computer can execute a data management application. The server computer can obtain a data partition associated with a data stream. The data partition can include a data point and a timestamp. The server computer can analyze the timestamp to determine if the data partition corresponds to an update of a base data record. If the server computer determines that the data corresponds to an update, the server computer can compute a revision comprising a delta and a timestamp and store the revision.

公开(公告)号：US20150095326A1

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

申请号：US14567295

申请日：2014-12-11

Applicant: AT&T Intellectual Property I, L.P.

Inventor： Theodore Johnson ,  Marios Hadjieleftheriou ,  Vladislav Shkapenyuk

IPC: G06F17/30

CPC classification number: G06F17/30525 ,  G06F17/30091 ,  G06F17/30424 ,  G06F17/30445 ,  G06F17/30486 ,  G06F17/30551 ,  G06F17/30864

Abstract: Concepts and technologies are disclosed herein for generating and using temporal metadata partitions. Metadata can be stored in temporal metadata partitions based upon a time range included in the metadata. Furthermore, metadata can be stored in multiple temporal metadata partitions to which the metadata is relevant. As such, metadata can be stored in manner that allows event data to be understood in the context of temporally accurate and/or relevant metadata. Functionality for executing queries of event data and providing results in view of metadata, as well as the merging of multiple temporal metadata partitions also are disclosed.

Abstract translation: 这里公开了用于生成和使用时间元数据分区的概念和技术。 元数据可以基于元数据中包含的时间范围存储在时间元数据分区中。 此外，元数据可以存储在元数据相关的多个时间元数据分区中。 因此，可以以允许在时间准确和/或相关元数据的上下文中理解事件数据的方式存储元数据。 还公开了用于执行事件数据的查询并且提供元数据的结果以及多个时间元数据分区的合并的功能。

公开(公告)号：US20230113558A1

公开(公告)日：2023-04-13

申请号：US17496964

申请日：2021-10-08

Applicant: AT&T Intellectual Property I, L.P.

Inventor： Theodore Johnson ,  Divesh Srivastava

IPC: G06F16/21 ,  G06F16/22

Abstract: A system for transforming data instances between two tree-structured schemas using a collection of bidirectional tree-structured schema modification operations.

公开(公告)号：US20180129698A1

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

申请号：US15345878

申请日：2016-11-08

Applicant: AT&T Intellectual Property I, L.P.

Inventor： Theodore Johnson ,  Vladislav Shkapenyuk

IPC: G06F17/30 ,  H04L9/06

CPC classification number: G06F16/24568 ,  H04L9/0643

Abstract: A device, method and computer-readable medium for generating unique identification for records in a data streaming processing system are disclosed. A method may collect an identification of a source of a data record, a timestamp of the data record and a count of a number of records a data source has added to the stream with that timestamp, generate a unique identification with the identification of the source of the data record, the timestamp of the data record and the count of the number of records the data source has added to the stream with that timestamp, apply the unique identification to the data record and transmit the data record with the unique identification to a downstream operator within a data stream processing system.

公开(公告)号：US20180081990A1

公开(公告)日：2018-03-22

申请号：US15268182

申请日：2016-09-16

Applicant: AT&T Intellectual Property I, L.P.

Inventor： Theodore Johnson ,  Vladislav Shkapenyuk

IPC: G06F17/30

CPC classification number: G06F16/90335 ,  G06F9/45558 ,  G06F16/9024 ,  G06F2009/45595

Abstract: A system may include a processor, a user input, and memory comprising a graph database and executable instructions. The executable instructions may cause the processor to effectuate operations. The operations include receiving, via the user input, a query comprising a class generalization and pathway variables. The operations include identifying a query class based on at least the class generalization and determining an anchor set based on at least one of the pathway variables. The operations also include translating the pathway variables into a pathway algebraic expression based on the anchor set and the query class and executing the pathway algebraic expression on the graph database to return a pathway set. The class generalization comprises at least one of a component, a class field, or metadata.