Skip to content

Instantly share code, notes, and snippets.

@kaiwaehner

kaiwaehner/Preprocessing with KSQL

Created January 9, 2019 08:52
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/981b5e4d1fb289fedbf8fd537cf42ea2 to your computer and use it in GitHub Desktop.
Save kaiwaehner/981b5e4d1fb289fedbf8fd537cf42ea2 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
Preprocessing with KSQL
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