Wie MLSQL Stack das Stream-Debugging vereinfacht

setze abc='''
{ "x": 100, "y": 200, "z": 200 ,"dataType":"A-Gruppe"}
{ "x": 120, "y": 100, "z": 260 ,"dataType":"B-Gruppe"}
{ "x": 120, "y": 100, "z": 260 ,"dataType":"B-Gruppe"}
{ "x": 120, "y": 100, "z": 260 ,"dataType":"B-Gruppe"}
{ "x": 120, "y": 100, "z": 260 ,"dataType":"B-Gruppe"}
{ "x": 120, "y": 100, "z": 260 ,"dataType":"B-Gruppe"}
{ "x": 120, "y": 100, "z": 260 ,"dataType":"B-Gruppe"}
{ "x": 120, "y": 100, "z": 260 ,"dataType":"B-Gruppe"}
{ "x": 120, "y": 100, "z": 260 ,"dataType":"B-Gruppe"}
{ "x": 120, "y": 100, "z": 260 ,"dataType":"B-Gruppe"}
{ "x": 120, "y": 100, "z": 260 ,"dataType":"B-Gruppe"}
''';
lade jsonStr.`abc` als Tabelle1;

Wählen Sie to_json(struct(*)) als Wert aus Tabelle1 als Tabelle2;
Speichern Sie „Anhängen von Tabelle2“ als „kafka.`wow`“, wobei 
kafka.bootstrap.servers="127.0.0.1:9092";

-- der Streamname sollte eindeutig sein.
setze streamName="streamExample";

-- verwenden Sie kafkaTool, um das Schema aus Kafka abzuleiten
!kafkaTool registerSchema 2 Datensätze von „127.0.0.1:9092“ wow;


Lade die Optionen von kafka.`wow` 
kafka.bootstrap.servers="127.0.0.1:9092"
als newkafkatable1;


Wählen Sie * aus newkafkatable1
als Tabelle21;


-- Drucken in der Webkonsole statt in der Terminalkonsole.
speichern anhängen table21 
als Webkonsole.`` 
Optionsmodus="Anhängen"
und Dauer="15"
und checkpointLocation="/tmp/s-cpl4";

-- der Streamname sollte eindeutig sein.
setze streamName="streamExample";


- einige Daten verspotten.
Daten festlegen='''
{"Schlüssel": "ja", "Wert": "nein", "Thema": "Test", "Partition": 0, "Offset": 0, "Zeitstempel": "2008-01-24 18:01:01.001", "Zeitstempeltyp": 0}
{"Schlüssel": "ja", "Wert": "nein", "Thema": "Test", "Partition": 0, "Offset": 1, "Zeitstempel": "2008-01-24 18:01:01.002", "Zeitstempeltyp": 0}
{"Schlüssel": "ja", "Wert": "nein", "Thema": "Test", "Partition": 0, "Offset": 2, "Zeitstempel": "2008-01-24 18:01:01.003", "Zeitstempeltyp": 0}
{"Schlüssel": "ja", "Wert": "nein", "Thema": "Test", "Partition": 0, "Offset": 3, "Zeitstempel": "2008-01-24 18:01:01.003", "Zeitstempeltyp": 0}
{"Schlüssel": "ja", "Wert": "nein", "Thema": "Test", "Partition": 0, "Offset": 4, "Zeitstempel": "2008-01-24 18:01:01.003", "Zeitstempeltyp": 0}
{"Schlüssel": "ja", "Wert": "nein", "Thema": "Test", "Partition": 0, "Offset": 5, "Zeitstempel": "2008-01-24 18:01:01.003", "Zeitstempeltyp": 0}
''';

-- Daten als Tabelle laden
lade jsonStr.`data` als Datenquelle;

--convert Tabelle als Streamquelle
Optionen für mockStream.`datasource` laden 
Schrittgrößenbereich="0-3"
als newkafkatable1;

-- Aggregation 
Wählen Sie Cast (Wert als Zeichenfolge) als k aus newkafkatable1
als Tabelle21;


!callback-Post „http://127.0.0.1:9002/api_v1/test“, wenn „gestartet, Fortschritt, beendet“;
-- geben Sie das Ergebnis auf der Konsole aus.


speichern anhängen table21 
als Benutzerdefiniert.`` 
Optionenmodus="Anhängen"
und Dauer="15"
und sourceTable="jack"
und Code='''
wähle count(*) als c von Jack als Newjack;
Speichern Sie „Newjack“ als Parquet anhängen. `/tmp/jack`; 
'''
und checkpointLocation="/tmp/cpl15";