Skip to content

Instantly share code, notes, and snippets.

@kaiwaehner

kaiwaehner/gist:e79749a8232a1d7bc3268ca71b8fa6f6

Created January 9, 2019 08:57
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save kaiwaehner/e79749a8232a1d7bc3268ca71b8fa6f6 to your computer and use it in GitHub Desktop.
Save kaiwaehner/e79749a8232a1d7bc3268ca71b8fa6f6 to your computer and use it in GitHub Desktop.
Download ZIP
KSQL Stream Table Join
Raw
gistfile1.txt
CREATE STREAM creditcardfraud_per_user WITH (VALUE_FORMAT='AVRO', KAFKA_TOPIC='creditcardfraud_preprocessed_avro') AS SELECT Time, V1 , V2 , V3 , V4 , V5 , V6 , V7 , V8 , V9 , V10 , V11 , V12 , V13 , V14 , V15 , V16 , V17 , V18 , V19 , V20 , V21 , V22 , V23 , V24 , V25 , V26 , V27 , V28 , Amount , Class FROM creditcardfraud_enahnced c INNER JOIN USERS u on c.userid = u.userid WHERE V1 > 5 AND V2 IS NOT NULL AND u.CITY LIKE 'Premium%';
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment