Computer Science ›› 2017, Vol. 44 ›› Issue (4): 140-143.doi: 10.11896/j.issn.1002-137X.2017.04.030

Previous Articles     Next Articles

CEStream:A Complex Event Stream Processing Language

WANG Yi-xiong, LIAO Hu-sheng, KONG Xiang-xuan, GAO Hong-yu and SU Hang   

  • Online:2018-11-13 Published:2018-11-13

Abstract: Complex event processing is one of the core technologies of stream processing platform which supports big data processing.A new style event stream processing language,named CEStream,supports complex event processing in distributed environment.This language takes hierarchical data as data model,such as XML,and also provides a feature for complex event detecting,which is named regular tree pattern matching.This feature supports structural connection and regular expression matching.Moreover,aiming at distributed multi-sources event stream,CEStream provides anotherfeature that matches each pattern matching result once again by regular expression which describes time sequence for each result.This feature supports the demand of multi-sources composite complex event detecting,and has good ability of event processing.To implement CEStream language,a process engine system was developed based on stream data processing cluster and remote querying agent.This system provides a feature which uses remote querying agent to detect events by regular tree pattern,and provides another feature which uses stream processing cluster to process multi-sources composite complex events.It’s demonstrated by experiments that this system has implemented CEStream language,has effectively made constraint on communication flows between each node in cluster,has capitalized on ability of cluster computing,and it supports the demand of comprehensive performance.

Key words: Complex event processing,Computer language,Stream computing

[1] ZHANG Q,CHENG L,BOUTABA R.Cloud computing:state-of-the-art and research challenges[J].Journal of Internet Servi-ces and Applications,2010,1(11):7-18.
[2] ZENG K,YANG M,MOZAFARI B,et al.Complex pattern mat-ching in complex structures:The XSeq approach[C]∥2013 IEEE 29th International Conference on Data Engineering (ICDE).IEEE,2013:1328-1331.
[3] BUGHIN J,CHUI M,MANYIKA J.Clouds,big data,and sma-rt assets:Ten tech-enabled business trends to watch[J].McKi- nsey Quarterly,2010,56:75-86.
[4] BAI Y,THAKKAR H,WANG H,et al.A data stream language and system designed for power and extensibility[C]∥CIKM.ACM,2006.
[5] CUGOLA G,MARGARA A.Processing flows of information:From data stream to complex event processing[J].ACM Computing Surveys (CSUR),2012,44(3):1-62.
[6] CUGOLA G,MARGARA A.RACED:an adaptive middleware for complex event detection[C]∥Proceedings of the 8th International Workshop on Adaptive and Reflective Middleware.ACM,2009:5.
[7] Peng F,Chawathe S S.Xpath queries on streaming data[C]∥SIGMOD.2003.
[8] DIAO Y,IMMERMAN N,GYLLSTROM D.Sase+:An agile language for kleene closure over event streams.[2012-12-23].http://archive,systems,,,pdf.
[9] ABADI D,CARNEY D,CETINTEMEL U,et al.Aurora:a data stream management system[C]∥SIGMOD.ACM,2003.
[10] RASANEN O,KAKOUROS S.Modeling Dependencies in Multiple Parallel Data Streams with Hyper dimensional Computing[J].Gnal Rong Lr,2014,21:899-903.
[11] AGUADO J,MENDLER M.Towards Strategies for Data Flow Programming[C]∥Preproceedings of the 22nd Symposium on Implementation and Application of Functional Languages (IFL 2010).2010:372-473.
[12] KIEBURTZ R B.Codata and comonads in Haskell[J/OL].

No related articles found!
Full text



[1] LEI Li-hui and WANG Jing. Parallelization of LTL Model Checking Based on Possibility Measure[J]. Computer Science, 2018, 45(4): 71 -75 .
[2] SUN Qi, JIN Yan, HE Kun and XU Ling-xuan. Hybrid Evolutionary Algorithm for Solving Mixed Capacitated General Routing Problem[J]. Computer Science, 2018, 45(4): 76 -82 .
[3] ZHANG Jia-nan and XIAO Ming-yu. Approximation Algorithm for Weighted Mixed Domination Problem[J]. Computer Science, 2018, 45(4): 83 -88 .
[4] WU Jian-hui, HUANG Zhong-xiang, LI Wu, WU Jian-hui, PENG Xin and ZHANG Sheng. Robustness Optimization of Sequence Decision in Urban Road Construction[J]. Computer Science, 2018, 45(4): 89 -93 .
[5] SHI Wen-jun, WU Ji-gang and LUO Yu-chun. Fast and Efficient Scheduling Algorithms for Mobile Cloud Offloading[J]. Computer Science, 2018, 45(4): 94 -99 .
[6] ZHOU Yan-ping and YE Qiao-lin. L1-norm Distance Based Least Squares Twin Support Vector Machine[J]. Computer Science, 2018, 45(4): 100 -105 .
[7] LIU Bo-yi, TANG Xiang-yan and CHENG Jie-ren. Recognition Method for Corn Borer Based on Templates Matching in Muliple Growth Periods[J]. Computer Science, 2018, 45(4): 106 -111 .
[8] GENG Hai-jun, SHI Xin-gang, WANG Zhi-liang, YIN Xia and YIN Shao-ping. Energy-efficient Intra-domain Routing Algorithm Based on Directed Acyclic Graph[J]. Computer Science, 2018, 45(4): 112 -116 .
[9] CUI Qiong, LI Jian-hua, WANG Hong and NAN Ming-li. Resilience Analysis Model of Networked Command Information System Based on Node Repairability[J]. Computer Science, 2018, 45(4): 117 -121 .
[10] WANG Zhen-chao, HOU Huan-huan and LIAN Rui. Path Optimization Scheme for Restraining Degree of Disorder in CMT[J]. Computer Science, 2018, 45(4): 122 -125 .