[go: up one dir, main page]

Kumar et al., 2019 - Google Patents

A TTL-based approach for data aggregation in geo-distributed streaming analytics

Kumar et al., 2019

View PDF
Document ID
6534477056028666998
Author
Kumar D
Li J
Chandra A
Sitaraman R
Publication year
Publication venue
Proceedings of the ACM on Measurement and Analysis of Computing Systems

External Links

Snippet

Streaming analytics require real-time aggregation and processing of geographically distributed data streams continuously over time. The typical analytics infrastructure for processing such streams follow a hub-and-spoke model, comprising multiple edges …
Continue reading at dl.acm.org (PDF) (other versions)

Classifications

    • GPHYSICS
    • G06COMPUTING; CALCULATING; COUNTING
    • G06FELECTRICAL DIGITAL DATA PROCESSING
    • G06F17/00Digital computing or data processing equipment or methods, specially adapted for specific functions
    • G06F17/30Information retrieval; Database structures therefor; File system structures therefor
    • G06F17/30286Information retrieval; Database structures therefor; File system structures therefor in structured data stores
    • G06F17/30386Retrieval requests
    • G06F17/30424Query processing
    • G06F17/30533Other types of queries
    • GPHYSICS
    • G06COMPUTING; CALCULATING; COUNTING
    • G06FELECTRICAL DIGITAL DATA PROCESSING
    • G06F11/00Error detection; Error correction; Monitoring
    • G06F11/30Monitoring
    • G06F11/34Recording or statistical evaluation of computer activity, e.g. of down time, of input/output operation; Recording or statistical evaluation of user activity, e.g. usability assessment
    • G06F11/3409Recording or statistical evaluation of computer activity, e.g. of down time, of input/output operation; Recording or statistical evaluation of user activity, e.g. usability assessment for performance assessment
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network-specific arrangements or communication protocols supporting networked applications
    • H04L67/10Network-specific arrangements or communication protocols supporting networked applications in which an application is distributed across nodes in the network
    • GPHYSICS
    • G06COMPUTING; CALCULATING; COUNTING
    • G06QDATA PROCESSING SYSTEMS OR METHODS, SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL, SUPERVISORY OR FORECASTING PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL, SUPERVISORY OR FORECASTING PURPOSES, NOT OTHERWISE PROVIDED FOR
    • G06Q30/00Commerce, e.g. shopping or e-commerce
    • G06Q30/02Marketing, e.g. market research and analysis, surveying, promotions, advertising, buyer profiling, customer management or rewards; Price estimation or determination
    • GPHYSICS
    • G06COMPUTING; CALCULATING; COUNTING
    • G06FELECTRICAL DIGITAL DATA PROCESSING
    • G06F2201/00Indexing scheme relating to error detection, to error correction, and to monitoring
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L12/00Data switching networks
    • H04L12/02Details
    • H04L12/26Monitoring arrangements; Testing arrangements
    • H04L12/2602Monitoring arrangements
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00Traffic regulation in packet switching networks
    • H04L47/10Flow control or congestion control
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00Arrangements for maintenance or administration or management of packet switching networks
    • H04L41/14Arrangements for maintenance or administration or management of packet switching networks involving network analysis or design, e.g. simulation, network model or planning
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L43/00Arrangements for monitoring or testing packet switching networks
    • GPHYSICS
    • G06COMPUTING; CALCULATING; COUNTING
    • G06FELECTRICAL DIGITAL DATA PROCESSING
    • G06F1/00Details of data-processing equipment not covered by groups G06F3/00 - G06F13/00, e.g. cooling, packaging or power supply specially adapted for computer application
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L63/00Network architectures or network communication protocols for network security

Similar Documents

Publication Publication Date Title
Kumar et al. A TTL-based approach for data aggregation in geo-distributed streaming analytics
US7739331B2 (en) Method and apparatus for providing load diffusion in data stream correlations
Lai et al. Oort: Efficient federated learning via guided participant selection
Heintz et al. Trading timeliness and accuracy in geo-distributed streaming analytics
US11818049B2 (en) Processing high volume network data
Hsieh et al. Gaia:{Geo-Distributed} machine learning approaching {LAN} speeds
JP5090054B2 (en) System and method for scalable processing of multipath data stream correlation
Logothetis et al. In-situ {MapReduce} for Log Processing
Heintz et al. Optimizing grouped aggregation in geo-distributed streaming analytics
US20160219089A1 (en) Systems and methods for messaging and processing high volume data over networks
CN107332889B (en) Cloud information management control system and control method based on cloud computing
US7925738B2 (en) Analytical cache performance model for a media server
WO2016115734A1 (en) Processing high volume network data
Heintz et al. Optimizing timeliness and cost in geo-distributed streaming analytics
US20230162047A1 (en) Massively Scalable, Resilient, and Adaptive Federated Learning System
US11500878B2 (en) Mechanism to synchronize, control, and merge data streams of disparate flow characteristics
Nicolaescu et al. Store edge networked data (SEND): A data and performance driven edge storage framework
Zhang et al. Parallelizing intra-window join on multicores: An experimental study
Kumar et al. Aggnet: Cost-aware aggregation networks for geo-distributed streaming analytics
US11632588B2 (en) Measuring the performance of a peer-managed content distribution network
Abdelkrim et al. A hybrid regression model for video popularity-based cache replacement in content delivery networks
Zulfa et al. Performance comparison of cache replacement algorithms onvarious internet traffic
Fu et al. DESIGN: Online device selection and edge association for federated synergy learning-enabled AIoT
Olston Approximate replication
WO2023005264A1 (en) Data processing method and apparatus