Academic literature on the topic 'Stream Processing System'
Create a spot-on reference in APA, MLA, Chicago, Harvard, and other styles
Consult the lists of relevant articles, books, theses, conference reports, and other scholarly sources on the topic 'Stream Processing System.'
Next to every source in the list of references, there is an 'Add to bibliography' button. Press on it, and we will generate automatically the bibliographic reference to the chosen work in the citation style you need: APA, MLA, Harvard, Chicago, Vancouver, etc.
You can also download the full text of the academic publication as pdf and read online its abstract whenever available in the metadata.
Journal articles on the topic "Stream Processing System"
Shuiying Yu, Shuiying Yu, Yinting Zheng Shuiying Yu, Fan Zhang Yinting Zheng, Hanhua Chen Fan Zhang, and Hai Jin Hanhua Chen. "TriJoin: A Time-Efficient and Scalable Three-Way Distributed Stream Join System." 網際網路技術學刊 24, no. 2 (March 2023): 475–85. http://dx.doi.org/10.53106/160792642023032402024.
Full textShi, Peng, and Li Li. "Design of Network Analysis System Based on Stream Computing." Journal of Computational and Theoretical Nanoscience 14, no. 1 (January 1, 2017): 64–68. http://dx.doi.org/10.1166/jctn.2017.6125.
Full textBernardelli de Moraes, Matheus, and André Leon Sampaio Gradvohl. "Evaluating the impact of a coordinated checkpointing in distributed data streams processing systems using discrete event simulation." Revista Brasileira de Computação Aplicada 12, no. 2 (May 19, 2020): 16–27. http://dx.doi.org/10.5335/rbca.v12i2.10295.
Full textValeev, S. S., N. V. Kondratyeva, A. S. Kovtunenko, M. A. Timirov, and R. R. Karimov. "Distributed stream data processing system in multi-agent safety system of infrastructure objects." Information Technology and Nanotechnology, no. 2416 (2019): 324–31. http://dx.doi.org/10.18287/1613-0073-2019-2416-324-331.
Full textYe, Qian, and Minyan Lu. "s2p: Provenance Research for Stream Processing System." Applied Sciences 11, no. 12 (June 15, 2021): 5523. http://dx.doi.org/10.3390/app11125523.
Full textAl Jawarneh, Isam Mashhour, Paolo Bellavista, Antonio Corradi, Luca Foschini, and Rebecca Montanari. "QoS-Aware Approximate Query Processing for Smart Cities Spatial Data Streams." Sensors 21, no. 12 (June 17, 2021): 4160. http://dx.doi.org/10.3390/s21124160.
Full textLi, Huiyong, Xiaofeng Wu, and Yanhong Wang. "Dynamic Performance Analysis of STEP System in Internet of Vehicles Based on Queuing Theory." Computational Intelligence and Neuroscience 2022 (April 10, 2022): 1–13. http://dx.doi.org/10.1155/2022/8322029.
Full textAkanbi, Adeyinka, and Muthoni Masinde. "A Distributed Stream Processing Middleware Framework for Real-Time Analysis of Heterogeneous Data on Big Data Platform: Case of Environmental Monitoring." Sensors 20, no. 11 (June 3, 2020): 3166. http://dx.doi.org/10.3390/s20113166.
Full textOtten, Lambert. "Wetdry composting of organic municipal solid waste: current status in Canada." Canadian Journal of Civil Engineering 28, S1 (January 1, 2001): 124–30. http://dx.doi.org/10.1139/l00-072.
Full textPark, Alfred J., Cheng-Hong Li, Ravi Nair, Nobuyuki Ohba, Uzi Shvadron, Ayal Zaks, and Eugen Schenfeld. "Towards flexible exascale stream processing system simulation." SIMULATION 88, no. 7 (August 9, 2011): 832–51. http://dx.doi.org/10.1177/0037549711412981.
Full textDissertations / Theses on the topic "Stream Processing System"
Wladdimiro, Cottet Daniel. "Dynamic adaptation in Stream Processing Systems." Electronic Thesis or Diss., Sorbonne université, 2024. http://www.theses.fr/2024SORUS028.
Full textThe amount of data produced by today’s web-based systems and applications increases rapidly, due to the many interactions with users (e.g. real-time stock market transactions, multiplayer games, streaming data produced by Twitter, etc.). As a result, there is a growing demand, particularly in the fields of commerce, security and research, for systems capable of processing this data in real time and providing useful information in a short space of time. Stream processing systems (SPS) meet these needs and have been widely used for this purpose. The aim of SPSs is to process large volumes of data in real time by housing a set of operators in applications based on Directed acyclic graphs (DAG). Most existing SPSs, such as Flink or Storm, are configured prior to deployment, usually defining the DAG and the number of operator replicas in advance. Overestimating the number of replicas can lead to a waste of allocated resources. On the other hand, depending on interaction with the environment, the rate of input data can fluctuate dynamically and, as a result, operators can become overloaded, leading to a degradation in system performance. These SPSs are not capable of dynamically adapting to operator workload and input rate variations. One solution to this problem is to dynamically increase the number of resources, physical or logical, allocated to the SPS when the processing demand of one or more operators increases. This thesis presents two SPSs, RA-SPS and PA-SPS, reactive and predictive approach respectively, for dynamically modifying the number of operator replicas. The reactive approach relies on the current state of operators computed on multiple metrics, while the predictive model is based on input rate variation, operator execution time, and queued events. The two SPSs extend Storm SPS to dynamically reconfigure the number of copies without having to downtime the application. They also implement a load balancer that distributes incoming events fairly among operator replicas. Experiments on the Google Cloud Platform (GCP) were carried out with applications that process Twitter data, DNS traffic, or logs traces. Performance was evaluated with different configurations and the results were compared with those of running the same applications on the original Storm as well as with state-of-the-art work such as SPS DABS-Storm, which also adapt the number of replicas. The comparison shows that both RA-SPS and PA-SPS can significantly improve the number of events processed, while reducing costs
Hongslo, Anders. "Stream Processing in the Robot Operating System framework." Thesis, Linköpings universitet, Artificiell intelligens och integrerad datorsystem, 2012. http://urn.kb.se/resolve?urn=urn:nbn:se:liu:diva-79846.
Full textKakkad, Vasvi. "Curracurrong: a stream processing system for distributed environments." Thesis, The University of Sydney, 2014. http://hdl.handle.net/2123/12861.
Full textTokmouline, Timur. "A signal oriented stream processing system for pipeline monitoring." Thesis, Massachusetts Institute of Technology, 2006. http://hdl.handle.net/1721.1/37106.
Full textIncludes bibliographical references (p. 115-117).
In this thesis, we develop SignalDB, a framework for composing signal processing applications from primitive stream and signal processing operators. SignalDB allows the user to focus on the signal processing task and avoid needlessly spending time on learning a particular application programming interface (API). We use SignalDB to express acoustic and pressure transient methods for water pipeline monitoring as query plans consisting of signal processing operators.
by Timur Tokmouline.
M.Eng.
Robakowski, Mikolaj. "Comparison of State Backends for Modern Stream Processing System." Thesis, KTH, Skolan för elektroteknik och datavetenskap (EECS), 2021. http://urn.kb.se/resolve?urn=urn:nbn:se:kth:diva-290597.
Full textDistribuerad strömbehandling är ett mycket populärt dataparadigm som användsi olika moderna datorsystem. En viktig aspekt av distribuerad strömbearbetningssystem är hur de hanterar data som är större än system minne.Detta löses ofta genom användning av en backend – en databas, vanligtvis eninbäddad, som hanterar lagringen. Detta gör dock att hela systemets prestandablir beroende av databasens prestanda för den angivna arbetsbelastningen.Loggstrukturerad merge-tree-baserade lösningar används ofta i strömbehandlingssystemsom en backend för alla typer av belastningar. Vi postulerar attanvända olika backends för olika arbetsbelastningar ger mycket bättre prestanda.I det här arbetet implementerar vi flera backends för Arcon, en modernströmbehandlings runtime skriven i Rust och utvecklad vid KTH. Avhandlingengår över implementeringsprocessen och gränssnittet för backends med flerakonkreta implementationer. Vi utvärderar experimentellt implementationernamot varandra och visar att vissa presterar bättre än andra beroende på arbetsbelastningen.I synnerhet visar vi att under läs-tungt arbete, så ser vi att sled,en inbäddad Bw-Tree databas skriven i Rust presterar bättre än den vanligaLSM-baserade RocksDB.
Mousavi, Bamdad. "Scalable Stream Processing and Management for Time Series Data." Thesis, Université d'Ottawa / University of Ottawa, 2021. http://hdl.handle.net/10393/42295.
Full textBalazinska, Magdalena. "Fault-tolerance and load management in a distributed stream processing system." Thesis, Massachusetts Institute of Technology, 2005. http://hdl.handle.net/1721.1/35287.
Full textThis electronic version was submitted by the student author. The certified thesis is available in the Institute Archives and Special Collections.
Includes bibliographical references (p. 187-199).
Advances in monitoring technology (e.g., sensors) and an increased demand for online information processing have given rise to a new class of applications that require continuous, low-latency processing of large-volume data streams. These "stream processing applications" arise in many areas such as sensor-based environment monitoring, financial services, network monitoring, and military applications. Because traditional database management systems are ill-suited for high-volume, low-latency stream processing, new systems, called stream processing engines (SPEs), have been developed. Furthermore, because stream processing applications are inherently distributed, and because distribution can improve performance and scalability, researchers have also proposed and developed distributed SPEs. In this dissertation, we address two challenges faced by a distributed SPE: (1) faulttolerant operation in the face of node failures, network failures, and network partitions, and (2) federated load management. For fault-tolerance, we present a replication-based scheme, called Delay, Process, and Correct (DPC), that masks most node and network failures.
(cont.) When network partitions occur, DPC addresses the traditional availability-consistency trade-off by maintaining, when possible, a desired availability specified by the application or user, but eventually also delivering the correct results. While maintaining the desired availability bounds, DPC also strives to minimize the number of inaccurate results that must later be corrected. In contrast to previous proposals for fault tolerance in SPEs, DPC simultaneously supports a variety of applications that differ in their preferred trade-off between availability and consistency. For load management, we present a Bounded-Price Mechanism (BPM) that enables autonomous participants to collaboratively handle their load without individually owning the resources necessary for peak operation. BPM is based on contracts that participants negotiate offline. At runtime, participants move load only to partners with whom they have a contract and pay each other the contracted price. We show that BPM provides incentives that foster participation and leads to good system-wide load distribution. In contrast to earlier proposals based on computational economies, BPM is lightweight, enables participants to develop and exploit preferential relationships, and provides stability and predictability.
(cont.) Although motivated by stream processing, BPM is general and can be applied to any federated system. We have implemented both schemes in the Borealis distributed stream processing engine. They will be available with the next release of the system.
by Magdalena Balazinska.
Ph.D.
Ahmed, Abdulbasit. "Online network intrusion detection system using temporal logic and stream data processing." Thesis, University of Liverpool, 2013. http://livrepository.liverpool.ac.uk/12153/.
Full textAl-Sinayyid, Ali. "JOB SCHEDULING FOR STREAMING APPLICATIONS IN HETEROGENEOUS DISTRIBUTED PROCESSING SYSTEMS." OpenSIUC, 2020. https://opensiuc.lib.siu.edu/dissertations/1868.
Full textAddimando, Alessio. "Progettazione di un intrusion detection system su piattaforma big data." Master's thesis, Alma Mater Studiorum - Università di Bologna, 2018. http://amslaurea.unibo.it/16755/.
Full textBooks on the topic "Stream Processing System"
Fredericks, Jeffrey W. Decision support system for conjunctive stream-aquifer management. Fort Collins, Colo: Colorado Water Resources Research Institute, 1995.
Find full textBabbitt, Ronald E. Improved streamflow and water quality monitoring using a microprocessor-based system. Ogden, UT]: U.S. Dept. of Agriculture, Forest Service, Intermountain Research Station, 1987.
Find full textBabbitt, Ronald E. Improved streamflow and water quality monitoring using a microprocessor-based system. [Ogden, UT]: U.S. Dept. of Agriculture, Forest Service, Intermountain Research Station, 1987.
Find full textDatacasting: How to stream databases over the Internet. New York: McGraw-Hill, 1998.
Find full textIFIP World Computer Congress (17th 2002 Montreál, Québec). Intelligent information processing: IFIP 17th World Computer Congress-TC12 stream on intelligent information processing, August 25-30, 2002, Montreál, Québec, Canada. Boston: Kluwer Academic, 2002.
Find full textEric, Yen, and ebrary Inc, eds. Oracle 11g Streams implementer's guide: Design, implement, and maintain a distributed environment with Oracle Streams. Birmingham, U.K: Packt Pub., 2010.
Find full textCorporation, International Business Machines, ed. IBM Infosphere Streams harnessing data in motion. [S.l.]: Vervante, 2010.
Find full textLane, Norman E. Users manual for the Automated Performance Test System (APTS). Orlando, FL: Essex Corp., 1990.
Find full textA, Hemstrom Miles, and Pacific Northwest Research Station (Portland, Or.), eds. Midscale analysis of streamside characteristics in the upper Grande Ronde subbasin, northeastern Oregon. Portland, OR: U.S. Dept. of Agriculture, Forest Service, Pacific Northwest Research Station, 2002.
Find full textKrivoyekov, Syergyey, and Roman Ayzman. Psychophysiology. ru: INFRA-M Academic Publishing LLC., 2015. http://dx.doi.org/10.12737/10884.
Full textBook chapters on the topic "Stream Processing System"
Gorawski, Marcin, Pawel Marks, and Michal Gorawski. "Modeling Data Stream Intensity in Distributed Stream Processing System." In Computer Networks, 372–83. Berlin, Heidelberg: Springer Berlin Heidelberg, 2013. http://dx.doi.org/10.1007/978-3-642-38865-1_38.
Full textGilani, Altaf, Satyajeet Sonune, Balakumar Kendai, and Sharma Chakravarthy. "The Anatomy of a Stream Processing System." In Flexible and Efficient Information Handling, 232–39. Berlin, Heidelberg: Springer Berlin Heidelberg, 2006. http://dx.doi.org/10.1007/11788911_20.
Full textLe, Jia-jin, and Jian-wei Liu. "DDSQP: A WSRF-Based Distributed Data Stream Query System." In Parallel and Distributed Processing and Applications, 833–44. Berlin, Heidelberg: Springer Berlin Heidelberg, 2005. http://dx.doi.org/10.1007/11576235_83.
Full textZrilic, Djuro G. "A Δ-Σ Digital Amplitude Modulation System." In Functional Processing of Delta-Sigma Bit-Stream, 75–82. Cham: Springer International Publishing, 2020. http://dx.doi.org/10.1007/978-3-030-47648-9_8.
Full textNishii, Shunsuke, and Toyotaro Suzumura. "Highly Scalable Speech Processing on Data Stream Management System." In Database Systems for Advanced Applications, 203–12. Berlin, Heidelberg: Springer Berlin Heidelberg, 2012. http://dx.doi.org/10.1007/978-3-642-29035-0_14.
Full textWang, Xiaotong, Junhua Fang, Yuming Li, Rong Zhang, and Aoying Zhou. "Cost-Effective Data Partition for Distributed Stream Processing System." In Database Systems for Advanced Applications, 623–35. Cham: Springer International Publishing, 2017. http://dx.doi.org/10.1007/978-3-319-55699-4_39.
Full textZrilic, Djuro G. "A Δ-Σ Digital Stereo Multiplexing–Demultiplexing System." In Functional Processing of Delta-Sigma Bit-Stream, 67–74. Cham: Springer International Publishing, 2020. http://dx.doi.org/10.1007/978-3-030-47648-9_7.
Full textZou, Beiji, Tao Zhang, Chengzhang Zhu, Ling Xiao, Meng Zeng, and Zhi Chen. "Alps: An Adaptive Load Partitioning Scaling Solution for Stream Processing System on Skewed Stream." In Lecture Notes in Computer Science, 17–31. Cham: Springer International Publishing, 2022. http://dx.doi.org/10.1007/978-3-031-12426-6_2.
Full textChakravarthy, Sharma, and Qingchun Jiang. "NFMi: AN INTER-DOMAIN NETWORK FAULT MANAGEMENT SYSTEM." In Stream Data Processing: A Quality of Service Perspective, 167–86. Boston, MA: Springer US, 2009. http://dx.doi.org/10.1007/978-0-387-71003-7_8.
Full textJiang, Jiawei, Zhipeng Zhang, Bin Cui, Yunhai Tong, and Ning Xu. "StroMAX: Partitioning-Based Scheduler for Real-Time Stream Processing System." In Database Systems for Advanced Applications, 269–88. Cham: Springer International Publishing, 2017. http://dx.doi.org/10.1007/978-3-319-55699-4_17.
Full textConference papers on the topic "Stream Processing System"
Park, Alfred J., Cheng-Hong Li, Ravi Nair, Nobuyuki Ohba, Uzi Shvadron, Ayal Zaks, and Eugen Schenfeld. "Flow: A Stream Processing System Simulator." In 2010 IEEE 24th Workshop on Principles of Advanced and Distributed Simulation (PADS 2010). IEEE, 2010. http://dx.doi.org/10.1109/pads.2010.5471658.
Full textLee, Myungcheol, Miyoung Lee, Sung Jin Hur, and Ikkyun Kim. "Load adaptive distributed stream processing system for explosive stream data." In 2015 17th International Conference on Advanced Communication Technology (ICACT). IEEE, 2015. http://dx.doi.org/10.1109/icact.2015.7224896.
Full textKwon, Oje, Yong-Soo Song, Jae-Hun Kim, and Ki-Joune Li. "SCONSTREAM: A Spatial Context Stream Processing System." In 2010 International Conference on Computational Science and Its Applications. IEEE, 2010. http://dx.doi.org/10.1109/iccsa.2010.48.
Full textKörber, Michael, Jakob Eckstein, Nikolaus Glombiewski, and Bernhard Seeger. "Event Stream Processing on Heterogeneous System Architecture." In the 15th International Workshop. New York, New York, USA: ACM Press, 2019. http://dx.doi.org/10.1145/3329785.3329933.
Full textMichalak, Peter, and Paul Watson. "PATH2iot: A Holistic, Distributed Stream Processing System." In 2017 IEEE International Conference on Cloud Computing Technology and Science (CloudCom). IEEE, 2017. http://dx.doi.org/10.1109/cloudcom.2017.35.
Full textWladdimiro, Daniel, Luciana Arantes, Pierre Sens, and Nicolas Hidalgo. "A Multi-Metric Adaptive Stream Processing System." In 2021 IEEE 20th International Symposium on Network Computing and Applications (NCA). IEEE, 2021. http://dx.doi.org/10.1109/nca53618.2021.9685871.
Full text"ITAIPU DATA STREAM MANAGEMENT SYSTEM - A Stream Processing System with Business Users in Mind." In 3rd International Conference on Software and Data Technologies. SciTePress - Science and and Technology Publications, 2008. http://dx.doi.org/10.5220/0001882000540064.
Full textWang, Shengxiang, Hansheng Lu, Zhiyun Gao, and Shanfeng Hou. "Multifunctional video stream processing system based on DSP." In Photonics Asia 2002, edited by LiWei Zhou, Chung-Sheng Li, and Yoshiji Suzuki. SPIE, 2002. http://dx.doi.org/10.1117/12.481567.
Full textAlves de Souza Ramos, Thatyene Louise, Rodrigo Silva Oliveira, Ana Paula de Carvalho, Renato Antonio Celso Ferreira, and Wagner Meira Jr. "Watershed: A High Performance Distributed Stream Processing System." In 2011 23rd International Symposium on Computer Architecture and High Performance Computing (SBAC-PAD). IEEE, 2011. http://dx.doi.org/10.1109/sbac-pad.2011.31.
Full textVogler, Michael, Johannes M. Schleicher, Christian Inzinger, Bernhard Nickel, and Schahram Dustdar. "Non-intrusive Monitoring of Stream Processing Applications." In 2016 IEEE Symposium on Service-Oriented System Engineering (SOSE). IEEE, 2016. http://dx.doi.org/10.1109/sose.2016.11.
Full textReports on the topic "Stream Processing System"
Alchanatis, Victor, Stephen W. Searcy, Moshe Meron, W. Lee, G. Y. Li, and A. Ben Porath. Prediction of Nitrogen Stress Using Reflectance Techniques. United States Department of Agriculture, November 2001. http://dx.doi.org/10.32747/2001.7580664.bard.
Full textChristopher, David A., and Avihai Danon. Plant Adaptation to Light Stress: Genetic Regulatory Mechanisms. United States Department of Agriculture, May 2004. http://dx.doi.org/10.32747/2004.7586534.bard.
Full textRon, Eliora, and Eugene Eugene Nester. Global functional genomics of plant cell transformation by agrobacterium. United States Department of Agriculture, March 2009. http://dx.doi.org/10.32747/2009.7695860.bard.
Full textSteffens, John C., and Eithan Harel. Polyphenol Oxidases- Expression, Assembly and Function. United States Department of Agriculture, January 1995. http://dx.doi.org/10.32747/1995.7571358.bard.
Full text