Skip to content

Instantly share code, notes, and snippets.

@confluentgist

confluentgist/gist:375dc18cc721ef57a123df508ff64500

Created February 5, 2019 05:19
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 confluentgist/375dc18cc721ef57a123df508ff64500 to your computer and use it in GitHub Desktop.
Save confluentgist/375dc18cc721ef57a123df508ff64500 to your computer and use it in GitHub Desktop.
Download ZIP
Preprocessing with KSQL
Raw
gistfile1.txt
CREATE STREAM creditcardfraud_preprocessed_avro 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_source WHERE Class IS NOT NULL;
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment