System przetwarzania strumieniowe­go: StreamAPAS v5.0

• Autorzy: Gorawski M. , Chrószcz A.

Warianty tytułu

EN

Stream processing system: StreamAPAS v5.0

• Języki publikacji: PL

Abstrakty

PL

Przedstawiony zostanie prototyp systemu przetwarzania strumienio­we­go StreamAPAS v5.0. Składnia języka zapytań tego systemu jest utworzona z myślą o zastosowaniach analitycznych, które wymagają obsługi struktur indeksu­ją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.

Słowa kluczowe

PL

drzewo atrybutów; podejście funkcjonalne; przetwarzanie strumieniowe; CQL; synchronizacja strumieni; okna czasowe; algebra temporalnych operatorów

EN

attributes tree; functional approach; stream processing; CQL; streams synchronization; time windows; temporal logical operator algebra

• Wydawca: Wydawnictwo Politechniki Śląskiej
• Czasopismo: Studia Informatica
• Rocznik: 2009
• Tom: Vol. 30, nr 1
• Strony: 7--34
• Opis fizyczny: bibliogr. 7 poz.

Twórcy

autor

Gorawski M.

autor

Chrószcz A.

• Instytut Informatyki Politechniki Śląskiej ul. Akademicka 16 44-100 Gliwice tel.: [phone],

Bibliografia

• Gorawski M., Skierski A.: Okienkowy język zapytań. II Krajowa Konferencja Naukowa "Technologie Przetwarzania Danych", 24-26 września 2007, Poznań.
• Balazinska M.: Fault-tolerance and load management in a Distributed Stream Processing System. PhD dissertation, Massachusetts institute of technology, February 2006.
• Kramer J., Seeger B.: A Temporal Foundation for Continuous Queries over Data Streams. Department of Mathematics and Computer Science PhilippsUniversity, Marburg, Germany, 11th International Conference on Management of Data (COMAD 2005).
• Arasu A., Babu S., Widom J.: The CQL Continuous Query Language Semantic Foundations and Query Execution. Stanford University, the International Journal on Very Large Databases (VLDB Journal) June 2006, 15:2, s. 121-142.
• Yu S., Atluri V., Adam N.: Optimizing View Materialization Cost in Spatial Data Warehouses. Lecture Notes in Computer Science 4081 Springer 2006, s. 45-54.
• Ardelli L., Ghelli G.: TQL: A Query Language for Semistructured Data Based on the Ambient logic. Mathematical structures in computer science 2004, Vol. 14; part 3, s. 285-328.
• Johannes, D. Leijen P.: The X Abroad - A Functional Approach To Software Components. Daan Leijen. PhD thesis, Department of Computer Science, Utrecht University, November 2003.