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.
Przedstawiony zostanie prototypowy język zapytań strumieniowych StreamAPAS v2.0 oraz system przetwarzania strumieniowego. Składnia języka StreamAPAS wspiera struktury hierarchiczne, które w czytelny sposób grupują atrybuty oraz reprezentują dane przestrzenne. Jednym z celów utworzonego systemu jest udostępnienie indeksów w przetwarzaniu strumieniowym. Wiąże się to z dodaniem nowych typów kolekcji krotek reprezentujących okna czasowe oraz rozbudową interfejsu funkcji. Rozwiązanie takie pozwala w prosty sposób zmieniać zbiór dostępnych funkcji, dzięki czemu łatwiej dostosować system przetwarzania strumieniowego do zmieniających się potrzeb aplikacji.
EN
The following paper introduces a new stream query language StreamAPAS v2.0 and the continuous processing system. The language syntax supports hierarchical data structures which offer grouping attributes and a better representation of spatial data. The paper describes also the extension of the data collections which enables the stream processing nodes to use indexes. The language syntax bases on the functional approach in order to simplify embedding new indexes and new functionality into the system. The above features make 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ć.