Bugfix for KSQL JOIN Query

Author: kaiwaehner

python-jupyter-apache-kafka-ksql-tensorflow-keras.ipynb

@@ -34,7 +34,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 14,
+   "execution_count": 8,
    "metadata": {
     "scrolled": true
    },
@@ -46,7 +46,7 @@
       "This CLI is intended for development only, not for production\n",
       "https://docs.confluent.io/current/cli/index.html\n",
       "\n",
-      "Using CONFLUENT_CURRENT: /var/folders/0s/0xdkb9n12yqdb3fs71926z3c0000gp/T/confluent.0nWtkbhu\n",
+      "Using CONFLUENT_CURRENT: /var/folders/0s/0xdkb9n12yqdb3fs71926z3c0000gp/T/confluent.RK2J2sUD\n",
       "Starting zookeeper\n",
       "zookeeper is [\u001b[0;32mUP\u001b[0m]\n",
       "Starting kafka\n",
@@ -59,7 +59,8 @@
     }
    ],
    "source": [
-    "! confluent start ksql-server"
+    "# Shows correct startup but does not work 100% yet. Better start from Terminal!\n",
+    "#! confluent start ksql-server"
    ]
   },
   {
@@ -287,7 +288,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 7,
+   "execution_count": 5,
    "metadata": {},
    "outputs": [
     {
@@ -311,7 +312,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 8,
+   "execution_count": 6,
    "metadata": {},
    "outputs": [
     {
@@ -320,7 +321,7 @@
        "True"
       ]
      },
-     "execution_count": 8,
+     "execution_count": 6,
      "metadata": {},
      "output_type": "execute_result"
     }
@@ -335,20 +336,33 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 12,
+   "execution_count": 7,
    "metadata": {},
-   "outputs": [],
+   "outputs": [
+    {
+     "data": {
+      "text/plain": [
+       "[{'@type': 'currentStatus',\n",
+       "  'statementText': \"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;\",\n",
+       "  'commandId': 'stream/CREDITCARDFRAUD_PER_USER/create',\n",
+       "  'commandStatus': {'status': 'SUCCESS',\n",
+       "   'message': 'Stream created and running'}}]"
+      ]
+     },
+     "execution_count": 7,
+     "metadata": {},
+     "output_type": "execute_result"
+    }
+   ],
    "source": [
-    "# TODO Bugfix needed in ksql-python to create a JOIN statement:\n",
-    "# https://github.com/bryanyang0528/ksql-python/issues/53\n",
-    "# client.ksql('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')"
+    "client.ksql(\"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\")"
    ]
   },
   {
    "cell_type": "markdown",
    "metadata": {},
    "source": [
-    "## TODO => The following section will be fixed soon (when Magnus is back at work)\n",
+    "## TODO => The following section will be fixed soon\n",
     "# Mapping from KSQL to Numpy / Pandas for Machine Learning Tasks"
    ]
   },