Big Data Developer
Current• Streamlined the Data Ingestion from different sources including Streaming, Batch, and Databases as part of AWS Data Lake implementation with the help of Spark on AWS Databricks, Delta Lake. • Contributed to multiple ETL batch and Stream processing Spark jobs to transform and load the data to different data zones in Pearson Data Lake. • Implemented the workflows using the Apache Airflow, and AWS Databricks Workflows to orchestrate job execution • Integration of AWS Databricks Unity Data Catalog as part of Datalake Governance. • Utilized Delta Lake, a reliable and scalable data lake solution on Azure Databricks, to ensure data integrity, ACID transactions, and versioning for large-scale data processing and analytics.• Developed and orchestrated complex data workflows using Databricks Jobs and Workflows, enabling automated data processing, scheduling, and monitoring.• Integrated AWS Databricks with AWS Data Lake Storage to efficiently store and manage structured, semi-structured, and unstructured data at scale, ensuring data governance and compliance.• Implemented data ingestion pipelines on AWS Databricks, using AWS S3, Apache Kafka, or other relevant technologies, for real-time and batch data streaming scenarios Worked on building the Prediction stream where we predict the streaming data from more than 100 deployed models on MLFlow using PySpark.• Discovery and implementation of generic rest services for the data lake starting from config service, metadata service, and many reusable client components with Python Django.• In-depth understanding of Spark Architecture including Spark Core, Spark SQL, and Data Frames.• Written transformations and actions on data frames, used Spark SQL on data frames to access hive tables into Spark for faster processing of data.• Involved in converting Hive/SQL queries into Spark transformations using Spark RDDs and Python.