Research On User-Defined Function Extending In A Complex Event Processing Language

With the development of big data,there is a lot of data generated in real time,and many industries need to analyze and deal with these data in a short time.Most of these data arrive in real-time,the the original data amount is huge but data value is small.To process these data,it need to in-depth analysis through specific rules reveal useful information.To better handle and respond to these big data,researchers began to propose real-time systems to accurately and quickly process data and extract valid information.Complex event processing is a kind of event flow-based technology.This technology uses event-driven architecture.It extract effective information from events by analyzing timing,aggregation,and other relationships between events.The existing complex event processing systems and languages mostly process each event in a same way,and do not support fine-grained query operations which filter different modes data into different branches.To meet the fine-grained query requirements,the study extend user-defined function that support fine-grained data processing in a complex event processing language CEStream.At the same time,the user-defiend function provides the user with the encapsulation function of the statement and improves the reusability of the language.The reaserach propose a method use formal parameter in stream pattern match type,recursive calls to functions,function overloading to achieve the effect of fine-grained processing stream data.The experimental results show that the extended function enables the language to support more fine-grained query requirements.At the same time,using the function when completing the same query requirement is basically use the same time as using the original statement.