Continuous Query Language - Versionsgeschichte

Feuerbird: /* Literatur */ Link zu Jennifer Widom

2022-08-14T15:58:21Z

Literatur: Link zu Jennifer Widom

← Nächstältere Version		Version vom 14. August 2022, 17:58 Uhr
Zeile 91:		Zeile 91:

	== Literatur ==		== Literatur ==
	* Brian Babcock, Shivnath Babu, Mayur Datar, [[Rajeev Motwani]], Jennifer Widom: ''[http://dbpubs.stanford.edu:8090/pub/2002-19 Models and Issues in Data Stream Systems]''. PODS 2002, Madison, Wisconsin.		* Brian Babcock, Shivnath Babu, Mayur Datar, [[Rajeev Motwani]], [[Jennifer Widom]]: ''[http://dbpubs.stanford.edu:8090/pub/2002-19 Models and Issues in Data Stream Systems]''. PODS 2002, Madison, Wisconsin.
	* Arvind Arasu, Shivnath Babu, Jennifer Widom: ''[http://dbpubs.stanford.edu/pub/2003-67 The CQL Continuous Query Language: Semantic Foundations and Query Execution]''. Stanford, 2003 (Technical Report)		* Arvind Arasu, Shivnath Babu, Jennifer Widom: ''[http://dbpubs.stanford.edu/pub/2003-67 The CQL Continuous Query Language: Semantic Foundations and Query Execution]''. Stanford, 2003 (Technical Report)
	* Rajeev Motwani, Jennifer Widom, Arvind Arasu, Brian Babcock, Shivnath Babu, Mayur Datar, Gurmeet Manku, Chris Olston, Justin Rosenstein und Rohit Varma: ''[http://newdbpubs.stanford.edu:8090/pub/2002-41 Query Processing, Resource Management, and Approximation in a Data Stream Management System]''. Stanford, 2002 (CIDR 2003)		* Rajeev Motwani, Jennifer Widom, Arvind Arasu, Brian Babcock, Shivnath Babu, Mayur Datar, Gurmeet Manku, Chris Olston, Justin Rosenstein und Rohit Varma: ''[http://newdbpubs.stanford.edu:8090/pub/2002-41 Query Processing, Resource Management, and Approximation in a Data Stream Management System]''. Stanford, 2002 (CIDR 2003)

Orthographus: Komma

2020-08-09T10:51:21Z

Komma

← Nächstältere Version		Version vom 9. August 2020, 12:51 Uhr
Zeile 63:		Zeile 63:

	=== Relation-Stream ===		=== Relation-Stream ===
	Der Operator <code>RSTREAM</code> wandelt eine gesamte Relation in einen Datenstrom um. Das heißt alle Tupel, die zum gegenwärtigen Zeitpunkt in der Relation enthalten sind, werden an den Datenstrom gesandt.		Der Operator <code>RSTREAM</code> wandelt eine gesamte Relation in einen Datenstrom um. Das heißt, alle Tupel, die zum gegenwärtigen Zeitpunkt in der Relation enthalten sind, werden an den Datenstrom gesandt.

	Das Schlüsselwort <code>NOW</code> für die Länge eines Fensters liefert in Verbindung mit dem Operator <code>RSTREAM</code> den aktuellen Wert. In folgendem Beispiel seien zwei Ströme Verbindungsaufbau und Verbindungsende gegeben, die jeweils den Anfang und das Ende einer Kommunikationsverbindung liefern. Die folgende Anfrage liefert fortlaufend alle abgeschlossenen Verbindungen, die höchstens 5 Minuten gedauert haben.		Das Schlüsselwort <code>NOW</code> für die Länge eines Fensters liefert in Verbindung mit dem Operator <code>RSTREAM</code> den aktuellen Wert. In folgendem Beispiel seien zwei Ströme Verbindungsaufbau und Verbindungsende gegeben, die jeweils den Anfang und das Ende einer Kommunikationsverbindung liefern. Die folgende Anfrage liefert fortlaufend alle abgeschlossenen Verbindungen, die höchstens 5 Minuten gedauert haben.

SovietBlini: "aktualisiert" ergänzt.

2017-01-14T16:35:57Z

"aktualisiert" ergänzt.

← Nächstältere Version		Version vom 14. Januar 2017, 18:35 Uhr
Zeile 71:		Zeile 71:
	: <code>WHERE A.id = E.id</code>		: <code>WHERE A.id = E.id</code>

	Mit dem Schlüsselwort <code>SLIDE</code> kann für ein Fenster angegeben werden, wie oft es aktualisiert werden soll. Die folgende Anfrage liefert beispielsweise täglich das gleitende Monatsmittel der gesamten Bestellsumme aus einem Strom von Bestellungen:		Mit dem Schlüsselwort <code>SLIDE</code> kann für ein Fenster angegeben werden, wie oft es aktualisiert werden soll, beziehungsweise wann das Fenster verschoben werden soll. Die folgende Anfrage liefert beispielsweise täglich das gleitende Monatsmittel der gesamten Bestellsumme aus einem Strom von Bestellungen:

	: <code>SELECT RSTREAM( AVG(B.Summe) ) FROM Bestellungen B [Range 1 Month Slide 1 Day]</code>		: <code>SELECT RSTREAM( AVG(B.Summe) ) FROM Bestellungen B [Range 1 Month Slide 1 Day]</code>

Vernanimalcula: /* Bestandteile */ So formuliert, dass ein Einsteiger auf einen Blick eine Übersicht gewinnt.

2015-04-22T07:14:23Z

Bestandteile: So formuliert, dass ein Einsteiger auf einen Blick eine Übersicht gewinnt.

← Nächstältere Version		Version vom 22. April 2015, 09:14 Uhr
Zeile 4:		Zeile 4:

	== Bestandteile ==		== Bestandteile ==
	Die wesentliche Erweiterung von CQL zu SQL besteht darin, dass zusätzlich zu [[Relation (Datenbank)\|Relationen]] auch [[Datenstrom\|Datenströme]] als Datentypen existieren. Datenströme lassen sich als potentiell unendliche Folge von Zeit-Wertepaaren auffassen. Für die Umwandlung zwischen Strömen und Relationen (siehe Abbildung) gibt es zwei verschiedene Arten von Operatoren.		Die wesentliche Erweiterung von CQL gegenüber SQL besteht darin, dass zusätzlich zu [[Relation (Datenbank)\|Relationen]] (Datenbanktabellen) auch [[Datenstrom\|Datenströme]] als Datentypen existieren.

			Datenströme lassen sich als potentiell unendliche Folgen von Zeit-Wertepaaren auffassen.
	Zur Umwandlung von Strömen in Relationen ist dies

			CQL definiert außerdem folgende ''Operatoren'', die in den nachfolgenden Abschnitten erläutert werden:

	* der Fenster-Operator <code>[[#Fenster\|<nowiki>[...]</nowiki>]]</code>		* der Fenster-Operator <code>[[#Fenster\|<nowiki>[...]</nowiki>]]</code>
	und zur Umwandlung von Relationen in Ströme
	* der Insert-Stream-Operator <code>[[#Insert-Stream\|ISTREAM]]</code>		* der Insert-Stream-Operator <code>[[#Insert-Stream\|ISTREAM]]</code>
	* der Delete-Stream-Operator <code>[[#Delete-Stream\|DSTREAM]]</code>		* der Delete-Stream-Operator <code>[[#Delete-Stream\|DSTREAM]]</code>
	* der Relation-Stream-Operator <code>[[#Relation-Stream\|RSTREAM]]</code>		* der Relation-Stream-Operator <code>[[#Relation-Stream\|RSTREAM]]</code>
			* der Stichproben-Operator <code>[[#Samples\|SAMPLE]]</code> für die Auswahl aus einem Datenstrom.

			Für die Transformation zwischen Relationen können die herkömmlichen Operatoren aus SQL verwendet werden.

	Zusätzlich gibt es den Stichproben-Operator <code>[[#Samples\|SAMPLE]]</code> für die Auswahl aus einem Datenstrom. Für die Transformation zwischen Relationen können die herkömmlichen Operatoren aus SQL verwendet werden. Die Umwandlung von Strömen in andere Ströme findet über den Umweg von Relationen statt~~. Die Operatoren sind weiter unten im Einzelnen erklärt~~.		Die Umwandlung von Strömen in andere Ströme findet über den Umweg von Relationen statt.

	== Beispiele ==		== Beispiele ==

Vernanimalcula: /* Die Operatoren im Einzelnen */ Kleine Verbesserungen und Vereinheitlichungen der Darstellung mit dem Ziel, die Verständlichkeit insgesamt zu erhöhen.

2015-04-22T07:04:07Z

Die Operatoren im Einzelnen: Kleine Verbesserungen und Vereinheitlichungen der Darstellung mit dem Ziel, die Verständlichkeit insgesamt zu erhöhen.

← Nächstältere Version		Version vom 22. April 2015, 09:04 Uhr
Zeile 35:		Zeile 35:
	=== Fenster ===		=== Fenster ===
	Zur Umwandlung von Strömen in Relationen wird ein ''Fenster'' definiert. Die Syntax dafür ist		Zur Umwandlung von Strömen in Relationen wird ein ''Fenster'' definiert. Die Syntax dafür ist
	<code>S [W]</code> wobei <code>S</code> ein Strom und <code>W</code> ein Fenster ist. Das Fenster kann durch einen Zeitraum oder durch eine Anzahl von Tupeln angegeben werden:		<code>S [W]</code>, wobei <code>S</code> ein Strom und <code>W</code> ein Fenster ist. Das Fenster kann durch einen Zeitraum oder durch eine Anzahl von Tupeln angegeben werden:

	: <code>[Rows 100]</code> liefert beispielsweise die jeweils 100 letzten Tupel		: <code>[Rows 100]</code> liefert beispielsweise die jeweils 100 letzten Tupel
Zeile 46:		Zeile 46:
	: <code>SELECT * FROM Bestellungen B<br /> [PARTITION BY B.Kunde ROWS 5]<br/> WHERE B.Zahlungsart = 'Kreditkarte'</code>		: <code>SELECT * FROM Bestellungen B<br /> [PARTITION BY B.Kunde ROWS 5]<br/> WHERE B.Zahlungsart = 'Kreditkarte'</code>

	In Verbindung mit dem <code>RSTREAM</code>~~-Operator~~ sind zusätzlich die Schlüsselwörter <code>NOW</code> und <code>SLIDE</code> möglich (siehe dort).		In Verbindung mit dem Operator <code>RSTREAM</code> sind zusätzlich die Schlüsselwörter <code>NOW</code> und <code>SLIDE</code> möglich (siehe dort).

	=== Insert-Stream ===		=== Insert-Stream ===
	Mit dem <code>ISTREAM</code>~~-Operator~~ wird aus einer Relation ein Datenstrom erstellt, bei dem jedes Mal, wenn ein Tupel in die Relation eingefügt wird, eine Kopie an den Datenstrom gesandt wird – allerdings nur, wenn es sich bei den eingefügten Tupeln nicht um Duplikate handelt. Die folgende Anfrage liefert mit jeder neuen Bestellung die Anzahl der Bestellungen innerhalb der letzten Stunde:		Mit dem Operator <code>ISTREAM</code> wird aus einer Relation ein Datenstrom erstellt, bei dem jedes Mal, wenn ein Tupel in die Relation eingefügt wird, eine Kopie an den Datenstrom gesandt wird – allerdings nur, wenn es sich bei den eingefügten Tupeln nicht um Duplikate handelt. Die folgende Anfrage liefert mit jeder neuen Bestellung die Anzahl der Bestellungen innerhalb der letzten Stunde:

	: <code>SELECT ISTREAM(COUNT(*)) ~~From~~ Bestellungen B [Range 1 Hour]</code>		: <code>SELECT ISTREAM(COUNT(*)) FROM Bestellungen B [Range 1 Hour]</code>

	=== Delete-Stream ===		=== Delete-Stream ===
	Mit dem <code>DSTREAM</code>~~-Operator~~ wird aus einer Relation ein Datenstrom erstellt, bei dem jedes Mal, wenn ein Tupel aus einer Relation entfernt wird, dieses Tupel an den Datenstrom gesandt wird. Die folgende Anfrage liefert die gelöschten Kunden als Datenstrom:		Mit dem Operator <code>DSTREAM</code> wird aus einer Relation ein Datenstrom erstellt, bei dem jedes Mal, wenn ein Tupel aus einer Relation entfernt wird, dieses Tupel an den Datenstrom gesandt wird. Die folgende Anfrage liefert die gelöschten Kunden als Datenstrom:

	: <code>DSTREAM (SELECT * FROM Kunden)</code>		: <code>DSTREAM (SELECT * FROM Kunden)</code>

	=== Relation-Stream ===		=== Relation-Stream ===
	Der <code>RSTREAM</code> ~~Operator~~ wandelt eine gesamte Relation ~~(beispielsweise eine gesamte Datenbanktabelle)~~ in einen Datenstrom um, ~~das~~ heißt alle Tupel, die zum gegenwärtigen Zeitpunkt in der Relation enthalten sind, werden an den Datenstrom gesandt.		Der Operator <code>RSTREAM</code> wandelt eine gesamte Relation in einen Datenstrom um. Das heißt alle Tupel, die zum gegenwärtigen Zeitpunkt in der Relation enthalten sind, werden an den Datenstrom gesandt.

	Das Schlüsselwort <code>NOW</code> für die Länge eines Fensters liefert in Verbindung mit dem ~~RSTREAM-~~Operator den aktuellen Wert. In folgendem Beispiel seien zwei Ströme Verbindungsaufbau und Verbindungsende gegeben, die jeweils den Anfang und das Ende einer Kommunikationsverbindung liefern. Die folgende Anfrage liefert fortlaufend alle abgeschlossenen Verbindungen, die höchstens 5 Minuten gedauert haben.		Das Schlüsselwort <code>NOW</code> für die Länge eines Fensters liefert in Verbindung mit dem Operator <code>RSTREAM</code> den aktuellen Wert. In folgendem Beispiel seien zwei Ströme Verbindungsaufbau und Verbindungsende gegeben, die jeweils den Anfang und das Ende einer Kommunikationsverbindung liefern. Die folgende Anfrage liefert fortlaufend alle abgeschlossenen Verbindungen, die höchstens 5 Minuten gedauert haben.

	: <code>SELECT RSTREAM(A.*)</code>		: <code>SELECT RSTREAM(A.*)</code>
Zeile 73:		Zeile 73:
	=== Samples ===		=== Samples ===

	Um eine zufällige Auswahl aus einem Stream zu bekommen, gibt es den <code>SAMPLE</code>~~-Operator~~, dem eine Prozentzahl übergeben wird. Beispielsweise ~~filtert~~ die Anfrage <code>SELECT * FROM T SAMPLE(10)</code> aus dem Stream <code>T</code> jedes Element mit einer Wahrscheinlichkeit von 90 % ~~heraus~~, so dass im Durchschnitt nur jedes zehnte in den Ergebnisstrom übernommen wird.		Um eine zufällige Auswahl aus einem Stream zu bekommen, gibt es den Operator <code>SAMPLE</code>, dem eine Prozentzahl übergeben wird. Beispielsweise gibt die Anfrage <code>SELECT * FROM T SAMPLE(10)</code> aus dem Stream <code>T</code> jedes Element nur mit einer Wahrscheinlichkeit von 10 % aus, so dass im Durchschnitt nur jedes zehnte in den Ergebnisstrom übernommen wird.

	== Bewertung ==		== Bewertung ==

Ute Erb am 23. November 2014 um 11:32 Uhr

2014-11-23T11:32:06Z

← Nächstältere Version		Version vom 23. November 2014, 13:32 Uhr
Zeile 40:		Zeile 40:
	: <code>[Range 5 Seconds]</code> liefert beispielsweise die Tupel der letzten 5 Sekunden		: <code>[Range 5 Seconds]</code> liefert beispielsweise die Tupel der letzten 5 Sekunden

	Wird kein Fenster angegeben, so wird <code>[∞]</code> angenommen, das heißt die Relation enthält alle Tupel aus dem Datenstrom bis zum aktuellen Zeitpunkt. Zusätzlich kann eine Beschränkung durch eine <code>WHERE</code>-Klausel und bei durch Tupelanzahl-basierten Fenstern eine Gruppierung mit <code>PARTITION BY</code> angegeben werden.		Wird kein Fenster angegeben, so wird <code>[∞]</code> angenommen, das heißt, die Relation enthält alle Tupel aus dem Datenstrom bis zum aktuellen Zeitpunkt. Zusätzlich kann eine Beschränkung durch eine <code>WHERE</code>-Klausel und bei durch Tupelanzahl-basierten Fenstern eine Gruppierung mit <code>PARTITION BY</code> angegeben werden.

	In folgendem Beispiel sei ein Strom „Bestellung“ mit den Attributen „Kunde“ und „Zahlungsart“ gegeben. Folgende Anfrage liefert jeweils die 5 letzten Bestellungen eines jeden Kunden, der mit Kreditkarte gezahlt hat.		In folgendem Beispiel sei ein Strom „Bestellung“ mit den Attributen „Kunde“ und „Zahlungsart“ gegeben. Folgende Anfrage liefert jeweils die 5 letzten Bestellungen eines jeden Kunden, der mit Kreditkarte gezahlt hat.

139.30.223.161: /* Relation-Stream */

2012-05-08T11:08:10Z

Relation-Stream

← Nächstältere Version		Version vom 8. Mai 2012, 13:08 Uhr
Zeile 69:		Zeile 69:
	Mit dem Schlüsselwort <code>SLIDE</code> kann für ein Fenster angegeben werden, wie oft es aktualisiert werden soll. Die folgende Anfrage liefert beispielsweise täglich das gleitende Monatsmittel der gesamten Bestellsumme aus einem Strom von Bestellungen:		Mit dem Schlüsselwort <code>SLIDE</code> kann für ein Fenster angegeben werden, wie oft es aktualisiert werden soll. Die folgende Anfrage liefert beispielsweise täglich das gleitende Monatsmittel der gesamten Bestellsumme aus einem Strom von Bestellungen:

	: <code>SELECT RSTREAM( AVG(B.Summe) ) FROM Bestellungen B [Range 1 ~~Year~~ Slide 1 ~~Month~~]</code>		: <code>SELECT RSTREAM( AVG(B.Summe) ) FROM Bestellungen B [Range 1 Month Slide 1 Day]</code>

	=== Samples ===		=== Samples ===

Aka: Leerzeichen vor Prozentzeichen eingefügt

2012-05-07T20:18:52Z

Leerzeichen vor Prozentzeichen eingefügt

← Nächstältere Version		Version vom 7. Mai 2012, 22:18 Uhr
Zeile 73:		Zeile 73:
	=== Samples ===		=== Samples ===

	Um eine zufällige Auswahl aus einem Stream zu bekommen, gibt es den <code>SAMPLE</code>-Operator, dem eine Prozentzahl übergeben wird. Beispielsweise filtert die Anfrage <code>SELECT * FROM T SAMPLE(10)</code> aus dem Stream <code>T</code> jedes Element mit einer Wahrscheinlichkeit von 90% heraus, so dass im Durchschnitt nur jedes zehnte in den Ergebnisstrom übernommen wird.		Um eine zufällige Auswahl aus einem Stream zu bekommen, gibt es den <code>SAMPLE</code>-Operator, dem eine Prozentzahl übergeben wird. Beispielsweise filtert die Anfrage <code>SELECT * FROM T SAMPLE(10)</code> aus dem Stream <code>T</code> jedes Element mit einer Wahrscheinlichkeit von 90 % heraus, so dass im Durchschnitt nur jedes zehnte in den Ergebnisstrom übernommen wird.

	== Bewertung ==		== Bewertung ==

Aka: Tippfehler entfernt

2011-11-19T12:24:20Z

Tippfehler entfernt

← Nächstältere Version		Version vom 19. November 2011, 14:24 Uhr
Zeile 14:		Zeile 14:
	* der Relation-Stream-Operator <code>[[#Relation-Stream\|RSTREAM]]</code>		* der Relation-Stream-Operator <code>[[#Relation-Stream\|RSTREAM]]</code>

	Zusätzlich gibt es den Stichproben-Operator <code>[[#Samples\|SAMPLE]]</code> für die Auswahl aus einem Datenstrom. Für die Transformation zwischen Relationen können die herkömmlichen Operatoren aus SQL verwendet werden. Die Umwandlung von Strömen in andere Ströme findet über den Umweg von Relationen statt. Die Operatoren sind weiter unten im ~~einzelnen~~ erklärt.		Zusätzlich gibt es den Stichproben-Operator <code>[[#Samples\|SAMPLE]]</code> für die Auswahl aus einem Datenstrom. Für die Transformation zwischen Relationen können die herkömmlichen Operatoren aus SQL verwendet werden. Die Umwandlung von Strömen in andere Ströme findet über den Umweg von Relationen statt. Die Operatoren sind weiter unten im Einzelnen erklärt.

	== Beispiele ==		== Beispiele ==

GFJ: Link

2011-07-31T09:49:53Z

Link

← Nächstältere Version		Version vom 31. Juli 2011, 11:49 Uhr
Zeile 80:		Zeile 80:
	Mit STREAM konkurrierende Systeme verwenden entweder direkt ein [[imperative Programmierung\|imperatives Modell]] zur Formulierung von Anfragen (beispielsweise [[Aurora/Borealis]]) oder besitzen eine mit CQL vergleichbare Syntax ([[TelegraphCQ]]) beziehungsweise ermöglichen prinzipiell auch die Ausführung von CQL-Anfragen ([[PIPES]]).		Mit STREAM konkurrierende Systeme verwenden entweder direkt ein [[imperative Programmierung\|imperatives Modell]] zur Formulierung von Anfragen (beispielsweise [[Aurora/Borealis]]) oder besitzen eine mit CQL vergleichbare Syntax ([[TelegraphCQ]]) beziehungsweise ermöglichen prinzipiell auch die Ausführung von CQL-Anfragen ([[PIPES]]).

	Die Verarbeitung von Anfragen über [[XML]]-Datenströmen stellt ein eigenes Forschungsgebiet dar, in dessen Rahmen auf [[XPath]] statt auf SQL aufbauende Anfragesprachen entwickelt werden.		Die Verarbeitung von Anfragen über [[Extensible Markup Language\|XML]]-Datenströmen stellt ein eigenes Forschungsgebiet dar, in dessen Rahmen auf [[XPath]] statt auf SQL aufbauende Anfragesprachen entwickelt werden.

	== Siehe auch ==		== Siehe auch ==