
This video will give complete objective of this course.
About Me
The agenda of this section is described in this video.
Download the following Documents
1. Creditcard Fraud detection.pdf
The complete project is explained & demonstrated in this document
2. Demonstration.pdf
This document contains only a demonstration and instructions to run the project
Technologies that you need to know upfront before taking this course
All the technology components that are required to implement this project
Brief introduction to Apache Spark
Introduction to Apache Kafka
Brief Introduction to Apache Cassandra
This video explains the architecture of real-time fraud detection project architecture.
Agenda of this section.
Learn how to install VirtualBox and import ubuntu image
Download code from github. Import code to Intellij
Should be able to start zookeeper server, kafka server, dashboard webserver, cassandra server. Create database and tables in Cassandra.
Learn how to run spark jobs from intellij.
Learn how to stop servers. Learn how to stop spark jobs and do project cleanup
Learn how to configure Apache Airflow with mysql database. Start and stop Airflow web server and airflow scheduler
Learn how to build maven project and start zookeeper server, kafka server, cassandra server, spark server.
Automate Real-time Fraud Detection Spark Jobs on Spark Standalone Cluster using Apache Airflow
Agenda of this Section
Structure of the Fraud Detection Project in Intellij
Implementation of Spark Job to read credit card data from file system and save to Cassandra database
Implementation of Spark Machine Learning Job to train of credit card transaction data
Implementation of Spark Streaming Job. Initialization Spark Streaming Job and Consuming credit card transactions from Kafka
Processing credit card transaction in real-time. Predicting whether a transaction is fraud or not in real-time
Saving predictions to Cassandra from Spark. Achieving Exactly once semantics in Spark Streaming.
Course Conclusion
Real-time Credit card Fraud Detection is implemented using Spark Kafka and Cassandra.
Spark ML Pipeline Stages like String Indexer, One Hot Encoder and Vector Assembler is used for Pre-processing
Machine Learning model is created using the Random Forest Algorithm
Data balancing is done using K-means Algorithm
Integration of Spark Streaming Job with Kafka and Cassandra
Exactly-once semantics is achieved using Spark Streaming custom offset management
Airflow Automation framework is used to automate Spark Jobs on Spark Standalone Cluster.