Skip to content

Commit a97700c

Browse files
committed
Bug fix for augmentation example
1 parent 3f28b4e commit a97700c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

live-demo___python-jupyter-apache-kafka-ksql-tensorflow-keras.adoc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -105,12 +105,12 @@ Some more examples how to use KSQL to preprocess and analyse the source data:
105105
SELECT Id, MASK_LEFT(User, 2) FROM creditcardfraud_source;
106106
107107
// Augmentation
108-
SELECT Id, IFNULL(Class, -1) FROM creditcardfraud_source;
108+
SELECT Id, IFNULL(Class, \'-1\') FROM creditcardfraud_source;
109109
110110
// STREAM-TABLE-JOIN
111111
kafka-topics --zookeeper localhost:2181 --create --topic users --partitions 3 --replication-factor 1
112112
113-
CREATE TABLE users (userid varchar, gender varchar, regionid varchar) WITH (kafka_topic='users', value_format='JSON', key = 'userid');
113+
CREATE TABLE users (userid varchar, gender varchar, regionid varchar) WITH (kafka_topic='users', value_format='AVRO', key = 'userid');
114114
115115
CREATE STREAM creditcardfraud_per_user WITH (VALUE_FORMAT='AVRO', KAFKA_TOPIC='creditcardfraud_per_user') AS SELECT Time, Amount, Class FROM creditcardfraud_source c INNER JOIN USERS u on c.user = u.userid WHERE u.USERID = 1;
116116
----

0 commit comments

Comments
 (0)