Przedstawiony zostanie prototyp systemu przetwarzania strumieniowego StreamAPAS v5.0. Składnia języka zapytań tego systemu jest utworzona z myślą o zastosowaniach analitycznych, które wymagają obsługi struktur indeksujących oraz możliwości prostego dodawania nowej funkcjonalności. Omówiono implementacje węzłów wyliczających agregaty oraz ich proces definiowania przez kompilator języka zapytań. Połączenie zalet drzewa atrybutów oraz interfejsu funkcji sprawia, że zbudowany system StreamAPAS v5.0 łatwo dostosować do zmieniających się potrzeb aplikacji.
EN
This paper introduces the prototype of the stream processing system StreamAPAS v5.0. The main goal of the engine and the query language is offering the general-purpose stream processing platform for data analysis. The language syntax simplify embedding new indexes and a new functionality. In this paper we focus on the implementation of the nodes calculating aggregates and the compiler algorithms used to define the aggregates. As it is further shown, the combination of hierarchical data structures and user aggregate defined functions makes continuous processing applications easier to develop and maintain.
JavaScript jest wyłączony w Twojej przeglądarce internetowej. Włącz go, a następnie odśwież stronę, aby móc w pełni z niej korzystać.