Rowkey как объединенный в Create Table from Stream в ksqlDB - PullRequest
Новая
       64

Rowkey как объединенный в Create Table from Stream в ksqlDB

0 голосов
/ 28 апреля 2020

Поток: 

CREATE STREAM SENSORS_KSTREAM (sensorid INT,
  serialnumber VARCHAR,
  mfgdate VARCHAR,
  productname VARCHAR,
  customerid INT,
  locationid INT,
  macaddress VARCHAR,
  installationdate VARCHAR)
WITH (KAFKA_TOPIC='SENSORS_DETAILS', VALUE_FORMAT='AVRO', KEY='sensorid');

Таблица, которую я создал с этим: 

CREATE TABLE SENSORS_KTABLE AS
SELECT sensorid, serialnumber, mfgdate, productname, customerid, locationid, macaddress, installationdate, COUNT(*) AS TOTAL 
FROM SENSORS_KSTREAM WINDOW TUMBLING (SIZE 1 MINUTES) 
GROUP BY sensorid, serialnumber, mfgdate, productname, customerid, locationid, macaddress, installationdate;

enter image description here

The ROWKEY произведено не то, что я хочу.

Я хочу только SENSORID в качестве ключа строки.

Может кто-нибудь помочь мне сделать это.

Заранее спасибо.

PS: Я использую автономный Confluent 5.4.0.

...