confluent

decodableco · Oct 27, 2022 · fc7f8d9 · fc7f8d9
1 parent ee02a94
commit fc7f8d9
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/confluent/clickstream_users_last_click.sql b/confluent/clickstream_users_last_click.sql
@@ -7,13 +7,12 @@ select
     e.ip,
     e.remote_user,
     e.`time`,
-    NOW() as _time,
+    cast(NOW() as timestamp) as _time,
     e.request,
     SPLIT_INDEX(e.request, ' ', 1) as url,
     e.status,
     e.`bytes`,
     e.referrer,
     e.agent
-from ecommerce_clickstream e
-inner join customers c on c.userid=e.userid
-
+from clickstream_avro e
+inner join customers_pg c on c.userid=e.userid