Kumar et al., 2019 - Google Patents
A TTL-based approach for data aggregation in geo-distributed streaming analyticsKumar 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 …
- 238000004220 aggregation 0 title abstract description 124
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING; COUNTING
- G06F—ELECTRICAL DIGITAL DATA PROCESSING
- G06F17/00—Digital computing or data processing equipment or methods, specially adapted for specific functions
- G06F17/30—Information retrieval; Database structures therefor; File system structures therefor
- G06F17/30286—Information retrieval; Database structures therefor; File system structures therefor in structured data stores
- G06F17/30386—Retrieval requests
- G06F17/30424—Query processing
- G06F17/30533—Other types of queries
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING; COUNTING
- G06F—ELECTRICAL DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/30—Monitoring
- G06F11/34—Recording 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/3409—Recording 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
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network-specific arrangements or communication protocols supporting networked applications
- H04L67/10—Network-specific arrangements or communication protocols supporting networked applications in which an application is distributed across nodes in the network
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING; COUNTING
- G06Q—DATA 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/00—Commerce, e.g. shopping or e-commerce
- G06Q30/02—Marketing, e.g. market research and analysis, surveying, promotions, advertising, buyer profiling, customer management or rewards; Price estimation or determination
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING; COUNTING
- G06F—ELECTRICAL DIGITAL DATA PROCESSING
- G06F2201/00—Indexing scheme relating to error detection, to error correction, and to monitoring
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L12/00—Data switching networks
- H04L12/02—Details
- H04L12/26—Monitoring arrangements; Testing arrangements
- H04L12/2602—Monitoring arrangements
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic regulation in packet switching networks
- H04L47/10—Flow control or congestion control
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance or administration or management of packet switching networks
- H04L41/14—Arrangements for maintenance or administration or management of packet switching networks involving network analysis or design, e.g. simulation, network model or planning
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L43/00—Arrangements for monitoring or testing packet switching networks
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING; COUNTING
- G06F—ELECTRICAL DIGITAL DATA PROCESSING
- G06F1/00—Details of data-processing equipment not covered by groups G06F3/00 - G06F13/00, e.g. cooling, packaging or power supply specially adapted for computer application
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L63/00—Network 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 |