Oracle CQL - Comptage du nombre de tuples après l'achèvement d'une fenêtre

Question

Je travaille sur un projet Oracle Event Processing dans Oracle Stream Analytics en utilisant JDeveloper.

J'ai un flux de données de 20 tuples sous forme de:

(attr1,attr2,attr3) 

1,1,1 

2,2,2 

.... 

20,20,20 

Je veux compter le nombre de tuples dans chaque fenêtre (je vais ajouter une condition plus tard à compter seulement tuples qui ne contiennent pas valeurs nulles). La sortie souhaitée est la suivante:

10 

10 

I essayé: SELECT COUNT (*) à partir du courant [10 lignes]. Cependant, je reçois:

0 

1 

2 

3 

4 

5 

6 

7 

8 

9 

10 

J'ai aussi essayé: Select count (*) de Stream [10 rows slide 10]. Cependant, je reçois:

0 

10 

Ma question est de savoir comment spécifier une requête qui renverra le nombre total de tuples (pour laquelle une condition est remplie) dans une fenêtre de taille N uniquement lorsque tous les N tuples arrivent?

Merci.

Answer 1

Votre deuxième requête devrait être ok, mais vous devez ajouter une clause ayant pour avoir la sortie que lorsque le nombre est 10.

<query id="ExampleQuery"><![CDATA[ 
    select count(*) as total from inputChannel [rows 10 slide 10] 
    having count(*) = 10 
    ]]></query> 

espère que cela peut aider.