{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,5,2]],"date-time":"2026-05-02T15:05:07Z","timestamp":1777734307009,"version":"3.51.4"},"reference-count":73,"publisher":"Springer Science and Business Media LLC","issue":"1","license":[{"start":{"date-parts":[[2016,8,1]],"date-time":"2016-08-01T00:00:00Z","timestamp":1470009600000},"content-version":"unspecified","delay-in-days":0,"URL":"http:\/\/www.springer.com\/tdm"}],"content-domain":{"domain":["link.springer.com"],"crossmark-restriction":false},"short-container-title":["Real-Time Syst"],"published-print":{"date-parts":[[2017,1]]},"DOI":"10.1007\/s11241-016-9257-0","type":"journal-article","created":{"date-parts":[[2016,8,1]],"date-time":"2016-08-01T17:47:46Z","timestamp":1470073666000},"page":"1-44","update-policy":"https:\/\/doi.org\/10.1007\/springer_crossmark_policy","source":"Crossref","is-referenced-by-count":45,"title":["Real-time processing of streaming big data"],"prefix":"10.1007","volume":"53","author":[{"given":"Ali A.","family":"Safaei","sequence":"first","affiliation":[],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"297","published-online":{"date-parts":[[2016,8,1]]},"reference":[{"issue":"2","key":"9257_CR1","doi-asserted-by":"crossref","first-page":"120","DOI":"10.1007\/s00778-003-0095-z","volume":"12","author":"D Abadi","year":"2003","unstructured":"Abadi D et al (2003) Aurora: a new model and architecture for data stream management. VLDB J 12(2):120\u2013139","journal-title":"VLDB J"},{"key":"9257_CR2","doi-asserted-by":"crossref","unstructured":"Alemi M, Safaei AA, Hagjhoo MS, Abdi F (2011) PDMRTS: multiprocessor real-time scheduling considering process distribution in data stream management system. In: International conference on digital information and communication technology and its applications, pp 166\u2013179","DOI":"10.1007\/978-3-642-22027-2_15"},{"key":"9257_CR3","doi-asserted-by":"crossref","unstructured":"Anderson J, Srinivasan A (2000) Early release fair scheduling. In: Proceedings of the euromicro conference on real-time systems. IEEE Computer Society Press, Stockholm, pp 35\u201343","DOI":"10.1109\/EMRTS.2000.853990"},{"issue":"1","key":"9257_CR4","doi-asserted-by":"crossref","first-page":"157","DOI":"10.1016\/j.jcss.2003.08.002","volume":"68","author":"J Anderson","year":"2004","unstructured":"Anderson J, Srinivasan A (2004) Mixed Pfair\/ERfair scheduling of asynchronous periodic tasks. J Comput Syst Sci 68(1):157\u2013204","journal-title":"J Comput Syst Sci"},{"key":"9257_CR5","doi-asserted-by":"crossref","unstructured":"Andersson B, Jonsson J (2003) The utilization bounds of partitioned and pfair static-priority scheduling on multiprocessors are 50 percent. In: 15th euromicro conference on real-time systems (ECRTS\u201903), Porto, Portugal, 02\u201304 July","DOI":"10.1109\/EMRTS.2003.1212725"},{"key":"9257_CR6","doi-asserted-by":"crossref","unstructured":"Andersson B, Tovar E (2006) Multiprocessor scheduling with few preemptions. In: Proceedings of the international conference on embedded and real-time computing systems and applications (RTCSA)","DOI":"10.1109\/RTCSA.2006.45"},{"key":"9257_CR7","doi-asserted-by":"crossref","unstructured":"Arasu A et al (2004) Linear road: a stream data management benchmark. In: Proceedings of the thirtieth international conference on very large data bases, vol 30. VLDB Endowment","DOI":"10.1016\/B978-012088469-8.50044-9"},{"key":"9257_CR8","doi-asserted-by":"crossref","unstructured":"\u00c5sberg M et al (2012) Exsched: an external cpu scheduler framework for real-time systems. In: 2012 IEEE 18th international conference on embedded and real-time computing systems and applications (RTCSA). IEEE","DOI":"10.1109\/RTCSA.2012.9"},{"key":"9257_CR9","unstructured":"Astrom KJ, Hagglund TH (1995) New tuning methods for PID controllers. In: Proceedings of the 3rd European control conference"},{"key":"9257_CR10","doi-asserted-by":"crossref","unstructured":"Babcock B et al (2003) Models and issues in data stream systems. In: Proceedings of the twenty-first ACM SIGMOD-SIGACT-SIGART symposium on principles of database systems","DOI":"10.1145\/543613.543615"},{"key":"9257_CR11","doi-asserted-by":"crossref","unstructured":"Babcock B et al (2004) Load shedding for aggregation queries over data streams. In: International conference on data engineering (ICDE)","DOI":"10.1109\/ICDE.2004.1320010"},{"issue":"4","key":"9257_CR12","doi-asserted-by":"crossref","first-page":"333","DOI":"10.1007\/s00778-004-0132-6","volume":"13","author":"B Babcock","year":"2004","unstructured":"Babcock B et al (2004) Operator scheduling in data stream systems. VLDB J 13(4):333\u2013353","journal-title":"VLDB J"},{"key":"9257_CR13","unstructured":"Bans JM, Arenas A, Labarta J (2002) Efficient scheme to allocate soft-aperiodic tasks in multiprocessor hard real-time systems. In: PDPTA, pp 809\u2013815"},{"key":"9257_CR14","doi-asserted-by":"crossref","first-page":"600","DOI":"10.1007\/BF01940883","volume":"15","author":"N Baruah","year":"1996","unstructured":"Baruah N et al (1996) Proportionate progress: a notion of fairness in resource allocation. Algorithmica 15:600\u2013625","journal-title":"Algorithmica"},{"key":"9257_CR15","doi-asserted-by":"crossref","unstructured":"Baruah S, Gehrke J, Plaxton C (1995) Fast scheduling of periodic tasks on multiple resources. In: Proceedings of the 9th international parallel processing symposium, April 1995, pp 280\u2013288","DOI":"10.1109\/IPPS.1995.395946"},{"key":"9257_CR16","doi-asserted-by":"crossref","first-page":"755","DOI":"10.1016\/j.future.2011.04.017","volume":"28","author":"A Beloglazov","year":"2012","unstructured":"Beloglazov A, Abawajy J, Buyya R (2012) Energy-aware allocation heuristics for efficient management of data centers for cloud computing. Future Gener Comput Syst 28:755\u2013768","journal-title":"Future Gener Comput Syst"},{"key":"9257_CR17","unstructured":"Bestavros A, Nagy S (1996) An admission control paradigm for real-time databases. Technical Report BUCS-TR-96-902, Computer Science Department, Boston University, Boston"},{"key":"9257_CR18","doi-asserted-by":"crossref","unstructured":"Bestavros A, Nagy S (1996) Value-cognizant admission control for RTDB systems. In: IEEE 16th real-time systems symposium, December 1996","DOI":"10.1109\/REAL.1996.563720"},{"key":"9257_CR19","doi-asserted-by":"crossref","unstructured":"Block A et al (2008) An adaptive framework for multiprocessor real-time system. In: Euromicro conference on real-time systems (ECRTS\u201908). IEEE","DOI":"10.1109\/ECRTS.2008.21"},{"issue":"6","key":"9257_CR20","doi-asserted-by":"crossref","first-page":"47","DOI":"10.1109\/2.846318","volume":"33","author":"G Bollella","year":"2000","unstructured":"Bollella G, James G (2000) The real-time specification for Java. Computer 33(6):47\u201354","journal-title":"Computer"},{"issue":"1\u20132","key":"9257_CR21","doi-asserted-by":"crossref","first-page":"285","DOI":"10.14778\/1920841.1920881","volume":"3","author":"Y Bu","year":"2010","unstructured":"Bu Y et al (2010) HaLoop: efficient iterative data processing on large clusters. Proc VLDB Endow 3(1\u20132):285\u2013296","journal-title":"Proc VLDB Endow"},{"key":"9257_CR22","unstructured":"Carpenter J et al (2004) A categorization of real-time multiprocessor scheduling problems and algorithms. In: Handbook on scheduling: algorithms, models and performance analysis"},{"key":"9257_CR23","doi-asserted-by":"crossref","first-page":"314","DOI":"10.1016\/j.ins.2014.01.015","volume":"275","author":"CL Chen Philip","year":"2014","unstructured":"Chen Philip CL, Zhang C-Y (2014) Data-intensive applications, challenges, techniques and technologies: a survey on big data. Inf Sci 275:314\u2013347","journal-title":"Inf Sci"},{"key":"9257_CR24","unstructured":"Condie T et al (2010) MapReduce Online.In: NSDI, vol. 10, no. 4"},{"key":"9257_CR25","unstructured":"Devi UC (2006) Soft real-time scheduling on multiprocessors. Ph.D. Thesis, University of North Carolina at Chapel Hill"},{"key":"9257_CR26","doi-asserted-by":"crossref","first-page":"127","DOI":"10.1287\/opre.26.1.127","volume":"26","author":"S Dhall","year":"1978","unstructured":"Dhall S, Liu C (1978) On a real-time scheduling problem. Oper Res 26:127\u2013140","journal-title":"Oper Res"},{"key":"9257_CR27","doi-asserted-by":"crossref","unstructured":"Elliott GA, Ward BC, Anderson JH (2013) GPUSync: a framework for real-time GPU management. In: 2013 IEEE 34th real-time systems symposium (RTSS). IEEE","DOI":"10.1109\/RTSS.2013.12"},{"key":"9257_CR28","unstructured":"Golab L (2004) Querying sliding windows over on-line data streams. In: Proceedings of ICDE\/EDBT Ph.D. workshop, March, pp 1\u201310"},{"key":"9257_CR29","doi-asserted-by":"crossref","unstructured":"Golatowski F et al (2002) Framework for validation, test and analysis of real-time scheduling algorithms and scheduler implementations. In: Proceedings of the 13th IEEE international workshop on rapid system prototyping, 2002. IEEE","DOI":"10.1109\/IWRSP.2002.1029750"},{"key":"9257_CR30","unstructured":"Graefe G et al (1994) Extensible query optimization and parallel execution in volcano. Query processing for advanced database systems, Morgan Kafman"},{"issue":"1\u20132","key":"9257_CR31","doi-asserted-by":"crossref","first-page":"125","DOI":"10.1007\/s11241-006-4687-8","volume":"32","author":"P Holman","year":"2006","unstructured":"Holman P, Anderson J (2006) Group-based pfair scheduling. Real Time Syst 32(1\u20132):125\u2013168","journal-title":"Real Time Syst"},{"key":"9257_CR32","unstructured":"http:\/\/www.espertech.com\/esper\/ . Accessed 20 May 2016"},{"key":"9257_CR33","unstructured":"https:\/\/storm.apache.org\/ . Accessed 20 March 2015"},{"issue":"1993","key":"9257_CR34","first-page":"347","volume":"712","author":"S Jamin","year":"1993","unstructured":"Jamin S et al (1993) An admission control algorithm for predictive real-time service. LNCS 712(1993):347\u2013356","journal-title":"LNCS"},{"key":"9257_CR35","doi-asserted-by":"crossref","unstructured":"Johnson T et al (2008) Query-aware partitioning for monitoring massive network data streams. In: SIGMOD","DOI":"10.1145\/1376616.1376730"},{"key":"9257_CR36","doi-asserted-by":"crossref","unstructured":"Kato S, Yamasaki N (2007) Real-time scheduling with task splitting on multiprocessors. In: Proceedings of the international conference on embedded and real-time computing systems and applications, pp 441\u2013450","DOI":"10.1109\/RTCSA.2007.61"},{"key":"9257_CR37","doi-asserted-by":"crossref","unstructured":"Kato S, Yamasaki N (2008) Portioned EDF-based scheduling on multiprocessors. In: Proceedings of the international conference on embedded software, pp 139\u2013148","DOI":"10.1145\/1450058.1450078"},{"key":"9257_CR38","doi-asserted-by":"crossref","unstructured":"Kato S, Yamasaki N (2008) Scheduling aperiodic tasks using total bandwidth server on multiprocessors. EUC, vol 1, pp 82\u201389","DOI":"10.1109\/EUC.2008.28"},{"key":"9257_CR39","doi-asserted-by":"crossref","unstructured":"Kleiminger W, Kalyvianaki E, Pietzuch P (2011) Balancing load in stream processing with the cloud.In: 2011 IEEE 27th international conference on data engineering workshops (ICDEW). IEEE","DOI":"10.1109\/ICDEW.2011.5767653"},{"key":"9257_CR40","doi-asserted-by":"crossref","unstructured":"Kontaki M (2010) Continuous processing of preference queries in data streams. In: 36th international conference on current trends in theory and practice of computer science (SOFSEM)","DOI":"10.1007\/978-3-642-11266-9_4"},{"key":"9257_CR41","unstructured":"Kramer J (2009) Continuous queries over data streams- semantics and implementation. kra"},{"key":"9257_CR42","doi-asserted-by":"crossref","unstructured":"Kulkarni S et al (2015) Twitter heron: stream processing at scale. In: Proceeding of the ACM SIGMOD\u201915, pp 239\u2013250","DOI":"10.1145\/2723372.2742788"},{"key":"9257_CR43","doi-asserted-by":"crossref","unstructured":"Kwon J, Cho H, Ravindran B (2012) A framework accommodating categorized multiprocessor real-time scheduling in the RTSJ. In: Proceedings of the 10th international workshop on java technologies for real-time and embedded systems. ACM","DOI":"10.1145\/2388936.2388941"},{"key":"9257_CR44","unstructured":"Lakshmanan K et al (2009) Partitioned fixed-priority preemptive scheduling formulti-core processors. In: Proceedings of the euromicro conference on real-time systems, pp 39\u2013248"},{"issue":"12","key":"9257_CR45","doi-asserted-by":"crossref","first-page":"1814","DOI":"10.14778\/2367502.2367520","volume":"5","author":"W Lam","year":"2012","unstructured":"Lam W et al (2012) Muppet: MapReduce-style processing of fast data. Proc VLDB Endow 5(12):1814\u20131825","journal-title":"Proc VLDB Endow"},{"key":"9257_CR46","doi-asserted-by":"crossref","DOI":"10.1007\/978-1-4614-6856-1","volume-title":"Web-scale data management for the cloud","author":"W Lehner","year":"2013","unstructured":"Lehner W, Sattler K-U (2013) Web-scale data management for the cloud. Springer, Berlin"},{"key":"9257_CR47","unstructured":"Leontyev H (2010) Compositional analysis techniques for multiprocessor soft real-time scheduling. Ph. D. Thesis, University of North Carolina at Chapel Hill"},{"key":"9257_CR48","unstructured":"Li X, Wang HA (2007) Adaptive real-time query scheduling over data streams. VLDB \u201907, 23\u201328 September, Vienna"},{"key":"9257_CR49","doi-asserted-by":"crossref","unstructured":"Lopez J, Garcia M, Diaz J, Garcia D (2000) Worst-case utilization bound for EDF scheduling on real-time multiprocessor systems. In: Proceedings of the 12th euromicro conference on real-time systems, June, pp 25\u201333","DOI":"10.1109\/EMRTS.2000.853989"},{"key":"9257_CR50","doi-asserted-by":"crossref","unstructured":"Ma L et al (2009) Real-time scheduling for continuous queries with deadlines. SAC\u201909, Honolulu, HI","DOI":"10.1145\/1529282.1529621"},{"key":"9257_CR51","doi-asserted-by":"crossref","first-page":"726","DOI":"10.1016\/j.sysarc.2014.07.004","volume":"60","author":"G-V Marisol","year":"2014","unstructured":"Marisol G-V, Tommaso C, Chenyang L (2014) Challenges in real-time virtualization and predictable cloud computing. J Syst Architect 60:726\u2013740","journal-title":"J Syst Architect"},{"key":"9257_CR52","unstructured":"Mohammadi S (2010) Continuous query response time improvement based on system conditions and stream featuress. M.Sc. Thesis, Iran University of Science and Technology"},{"key":"9257_CR53","doi-asserted-by":"crossref","unstructured":"Neumeyer L et al (2010) S4: distributed stream computing platform. 2010 IEEE international conference on data mining workshops (ICDMW). IEEE","DOI":"10.1109\/ICDMW.2010.172"},{"key":"9257_CR54","doi-asserted-by":"crossref","unstructured":"Regehr J, Stankovic JA (2001) HLS: a framework for composing soft real-time schedulers. In: Proceedings of the 22nd IEEE real-time systems symposium (RTSS 2001). IEEE","DOI":"10.1109\/REAL.2001.990591"},{"key":"9257_CR55","doi-asserted-by":"crossref","unstructured":"Safaei AA, Haghjoo MS, Abdi F (2011) PFGN: a hybrid multiprocessor real-time scheduling algorithm for data stream management systems. In: Proceeding of international conference on digital information and communication technology and its applications, pp 180\u2013192","DOI":"10.1007\/978-3-642-22027-2_16"},{"issue":"2","key":"9257_CR56","first-page":"171","volume":"8","author":"AA Safaei","year":"2011","unstructured":"Safaei AA, Alemi M, Haghjoo MS, Mohammadi S (2011) Hybrid multiprocessor real-time scheduling approach. Int J Comput Sci Issues 8(2):171","journal-title":"Int J Comput Sci Issues"},{"issue":"2","key":"9257_CR57","doi-asserted-by":"publisher","first-page":"145","DOI":"10.1007\/s10619-012-7090-6","volume":"30","author":"AA Safaei","year":"2012","unstructured":"Safaei AA, Sharif-Razavian A, Sharifi M, Haghjoo MS (2012) Dynamic routing of data stream tuples among parallel query plan running on multi-core processors. J Distrib Parallel Databases 30(2):145\u2013176. doi: 10.1007\/s10619-012-7090-6","journal-title":"J Distrib Parallel Databases"},{"issue":"2\u20133","key":"9257_CR58","doi-asserted-by":"publisher","first-page":"93","DOI":"10.1007\/s10619-010-70663","volume":"28","author":"AA Safaei","year":"2010","unstructured":"Safaei AA, Haghjoo MS (2010) Parallel processing of continuous queries over data streams. Distrib Parallel Databases 28(2\u20133):93\u2013118. doi: 10.1007\/s10619-010-70663","journal-title":"Distrib Parallel Databases"},{"issue":"3","key":"9257_CR59","doi-asserted-by":"publisher","first-page":"619","DOI":"10.1007\/s11227-011-0621-5","volume":"61","author":"AA Safaei","year":"2012","unstructured":"Safaei AA, Haghjoo MS (2012) Dispatching of stream operators in parallel execution of continuous queries. J Supercomput 61(3):619\u2013641. doi: 10.1007\/s11227-011-0621-5","journal-title":"J Supercomput"},{"issue":"2","key":"9257_CR60","first-page":"11","volume":"11","author":"AA Safaei","year":"2014","unstructured":"Safaei AA, Haghjoo MS (2014) Parallel processing of data streams. J Comput Sci Eng 11(2):11\u201329","journal-title":"J Comput Sci Eng"},{"key":"9257_CR61","unstructured":"Srinivasan A (2003) Effcient and flexible fair scheduling of real-time tasks on multiprocessors. Ph.D. Thesis, University of North Carolina, Chapel Hill"},{"issue":"3","key":"9257_CR62","first-page":"1","volume":"1","author":"A Srinivasan","year":"2004","unstructured":"Srinivasan A, Anderson JH (2004) Efficient scheduling of soft real-time applications on multiprocessors. J Embed Comput 1(3):1\u201314","journal-title":"J Embed Comput"},{"issue":"6","key":"9257_CR63","doi-asserted-by":"crossref","first-page":"29","DOI":"10.1109\/2.769440","volume":"32","author":"JA Stankovic","year":"1999","unstructured":"Stankovic JA et al (1999) Misconceptions about real-time databases. J Comput 32(6):29\u201336","journal-title":"J Comput"},{"issue":"4","key":"9257_CR64","doi-asserted-by":"crossref","first-page":"247","DOI":"10.1007\/BF01995673","volume":"2","author":"JA Stankovic","year":"1990","unstructured":"Stankovic JA, Ramamritham K (1990) What is predictability for real-time systems? Real Time Syst 2(4):247\u2013254","journal-title":"Real Time Syst"},{"issue":"4","key":"9257_CR65","doi-asserted-by":"crossref","first-page":"42","DOI":"10.1145\/1107499.1107504","volume":"34","author":"M Stonebraker","year":"2005","unstructured":"Stonebraker M et al (2005) The 8 requirements of real-time stream processing. SIGMOD Rec 34(4):42\u201347","journal-title":"SIGMOD Rec"},{"key":"9257_CR66","doi-asserted-by":"crossref","unstructured":"Tatbul N et al (2003) Load shedding in a data stream manager. In: Proceedings of VLDB, pp 309\u2013320","DOI":"10.1016\/B978-012722442-8\/50035-5"},{"key":"9257_CR67","unstructured":"The STREAM Group (2003) STREAM: the Stanford stream data manager. IEEE data engineering bulletin, March 2003"},{"issue":"1","key":"9257_CR68","doi-asserted-by":"crossref","first-page":"228","DOI":"10.1109\/TII.2012.2198662","volume":"9","author":"MG Valls","year":"2013","unstructured":"Valls MG, Lopez IR, Villar LF (2013) iLAND: an enhanced middleware for real-time reconfiguration of service oriented distributed real-time systems. IEEE Trans Ind Inform 9(1):228\u2013236","journal-title":"IEEE Trans Ind Inform"},{"key":"9257_CR69","doi-asserted-by":"crossref","unstructured":"Wei Y et al (2007) QoS management of real-time data stream queries in distributed environments. In: IEEE international symposium on object-oriented real-time distributed","DOI":"10.1109\/ISORC.2007.49"},{"key":"9257_CR70","unstructured":"Wei Y, Son SH, Stankovic JA (2006a) RTSTREAM: real-time query processing for data streams. In: 9th IEEE international symposium on object\/component\/service-oriented real-time distributed computing, pp 141\u2013150"},{"key":"9257_CR71","doi-asserted-by":"crossref","unstructured":"Wei Y, Prasad V, Son SH, Stankovic J (2006b) Prediction-based QoS management for real-time data stream. In: Proceedings of IEEE real-time systems symposium (RTSS\u201906), December","DOI":"10.1109\/RTSS.2006.34"},{"key":"9257_CR72","doi-asserted-by":"crossref","unstructured":"Yang, H et al (2007) Map-reduce-merge: simplified relational data processing on large clusters. In: Proceedings of the 2007 ACM SIGMOD international conference on management of data. ACM","DOI":"10.1145\/1247480.1247602"},{"issue":"3","key":"9257_CR73","doi-asserted-by":"crossref","first-page":"113","DOI":"10.1016\/S0968-090X(96)00006-X","volume":"4","author":"Q Yang","year":"1996","unstructured":"Yang Q, Koutsopoulos HN (1996) A microscopic traffic simulator for evaluation of dynamic traffic management systems. Transp Res C 4(3):113\u2013129","journal-title":"Transp Res C"}],"container-title":["Real-Time Systems"],"original-title":[],"language":"en","link":[{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/s11241-016-9257-0.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"text-mining"},{"URL":"http:\/\/link.springer.com\/article\/10.1007\/s11241-016-9257-0\/fulltext.html","content-type":"text\/html","content-version":"vor","intended-application":"text-mining"},{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/s11241-016-9257-0","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"},{"URL":"http:\/\/link.springer.com\/content\/pdf\/10.1007\/s11241-016-9257-0.pdf","content-type":"application\/pdf","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2019,9,12]],"date-time":"2019-09-12T01:27:33Z","timestamp":1568251653000},"score":1,"resource":{"primary":{"URL":"http:\/\/link.springer.com\/10.1007\/s11241-016-9257-0"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2016,8,1]]},"references-count":73,"journal-issue":{"issue":"1","published-print":{"date-parts":[[2017,1]]}},"alternative-id":["9257"],"URL":"https:\/\/doi.org\/10.1007\/s11241-016-9257-0","relation":{},"ISSN":["0922-6443","1573-1383"],"issn-type":[{"value":"0922-6443","type":"print"},{"value":"1573-1383","type":"electronic"}],"subject":[],"published":{"date-parts":[[2016,8,1]]}}}