AT&T Intellectual Property I, LP

Emory University

Tamraparni Dasu

Divesh Srivastava

Yaron Kanza

Eleftherios Koutsofios

Vladislav Shkapenyuk

Rajat Malik

Li Xiong

Deborah F Swayne

Shuaicheng Ma

Teddy Chu

Gordon Woodhull

Jon R Wright

Gregg Vesonder

Aspects of the subject disclosure may include, for example, detecting data streams by a processing system including a processor, wherein the processing system is associated with an anomaly detection and alerting system in which stream processing and model maintenance is decoupled from one another, and wherein one or more dedicated virtual machines (VMs) store and maintain anomaly detection and alerting models, based on the detecting, causing, by the processing system, a plurality of stream-processing VMs to be instantiated for processing the data streams, and managing, by the processing system, data stream assignments for the plurality of stream-processing VMs based on monitoring of one or more conditions, wherein the plurality of stream-processing VMs process assigned data streams by executing instances of the anomaly detection and alerting models, and provide model outputs to the one or more dedicated VMs for updating of the anomaly detection and alerting models. Other embodiments are disclosed.

System and method for cloud-based anomaly detection and alerting for streaming data

Aspects of the subject disclosure may include, for example, a device including a processing system including a processor; and a memory that stores executable instructions that, when executed by the processing system, define operations of modules that monitor a computational hierarchy, the modules include a first module for generating base alerts with a hierarchical key associated with an operation of the computational hierarchy and for rolling up the base alerts based on the computational hierarchy, resulting in rolled-up base alerts; a second module for generating super alerts from a concentration of the rolled up base alerts; and a third module comprising a first plurality of models that selects the super alerts based on priority, persistence of anomalies, pervasiveness of the super alerts generated, recency, or a combination thereof, generates a smart alert based on voting on the super alerts selected by the first plurality of models, and presents the smart alert on a user interface. Other embodiments are disclosed.

Architecture for scalable smart alerting across a multitude of data streams

Aspects of the subject disclosure may include, for example, a non-transitory, machine-readable medium, comprising executable instructions that, when executed by a processing system including a processor, facilitate performance of operations including receiving a call; selecting a next carrier to handoff the call; generating a call data record (CDR) for the handoff to the next carrier; encrypting the CDR using a call encryption key, thereby creating an encrypted CDR; encrypting the encrypted CDR using a committee encryption key, thereby creating a double encrypted CDR; recording the double encrypted CDR to a blockchain; and sending the call encryption key to the next carrier. Other embodiments are disclosed.

System and method for mitigating international revenue share fraud

Aspects of the subject disclosure may include, for example, a device with a processing system including a processor; and a memory that stores executable instructions that, when executed by the processing system, facilitate performance of operations including receiving a first record of sending a file and a hash for the file from a sender of the file; recording the first record on a blockchain; providing the first record to a receiver of the file; and monitoring a predetermined time period in which to receive a second record of receiving the file and the hash for the file. Other embodiments are disclosed.

Blockchain-powered ledger for a data supply chain

Concepts and technologies disclosed herein are directed to location-based blockchain. A localized corroborator system can receive, from a user device, an initiation message including a public key, and in response, can generate and send the random session identifier to the user device. The system can receive, from the user device, a signed session identifier including the random session identifier signed by the user device using a private key. The system can check a time that elapsed between sending the random session identifier to the user device and receiving the signed session identifier from the user device. The system can verify authenticity of the signed session identifier using the public key. In response to the time being less than a pre-defined threshold, the system can issue a location certificate to the user device. The user device can utilize the location certificate to conduct a certified blockchain transaction in a blockchain.

Location-based blockchain

A system for providing continuous monitoring of data quality in a dynamic feed environment is disclosed. In particular, the system utilizes a feed inspection tool to detect anomalies in data gathering detected from feed metadata and anomalies in data measurement detected based on file contents. In order to do so, the feed inspection tool may aggregate, for a plurality of aggregation intervals, data feeds and associated metadata feeds. Once the data feeds and metadata feeds are aggregated, the feed inspection tool may generate, for a baseline model feed, baseline statistical models by utilizing historical data of the aggregated feeds in sliding windows of different lengths. The feed inspection tool may then identify, for a plurality of monitoring time delays, data outliers by comparing the aggregated feeds with the baseline model feed. A data quality feed based on the data outliers identified may then be generated and published.

System for continuous monitoring of data quality in a dynamic feed environment

Managing and monitoring multiple complex data feeds is a major challenge for data mining tasks in large corporations and scientific endeavors alike. The invention describes an effective method for flagging abnormalities in data feeds using an ensemble of statistical tests that may be used on complex data feeds. The tests in the ensemble are chosen such that the speed and ability to deliver real time decisions are not compromised.

Growing community of inventors

New Vernon, NJ, United States of America

Tamraparni Dasu