KSQL로 모든 항목 계산하기

Question

GROUP BY을 통해 특정 열의 항목을 계산하는 대신 KSQL을 사용하는 대신 응용 프로그램을 통해 스트리밍되는 모든 항목에 대한 집계를 얻을 수 있습니까?

이 같은 뭔가를 찾고 있어요 :

| Count all | Count id1 | count id2 | 
| ---245----|----150----|----95-----| 

이상 KSQL이 같은 :

[some timestamp] | Count all | 245 
[some timestamp] | Count id1 | 150 
[some timestamp] | Count id2 | 95 
. 
. 
. 

당신에게
감사 - 팀을

는

Answer 1

당신은 모두 수를 가질 수 없습니다 모두 동일한 쿼리에서 각 키의 개수입니다. 주어진 열의 각 값을 세는 데 하나씩, 주어진 열의 모든 값을 세는 데 두 개의 쿼리를 사용할 수 있습니다. 두 개의 열 col1 및 col2가있는 스트림이 있다고 가정합니다.

SELECT col1, count(*) FROM mystream1 GROUP BY col1; 

당신이 KSQL 항상 집계 GROUP BY 절을 필요로하기 때문에 두 개의 쿼리를 작성하는 데 필요한 모든 행을 계산하려면 : 는 다음 쿼리를 사용할 수있는 무한 창 크기와 COL1의 각 값을 계산합니다. 먼저 상수 값으로 새 열을 만든 다음 새 열에서 값을 계산할 수 있으며 상수이므로 개수가 모든 행 수를 나타냅니다. 다음은 그 예이다 :

CREATE STREAM mystream2 AS SELECT 1 AS col3 FROM mystream1; 
SELECT col3, count(*) FROM mystream2 GROUP BY col3;