Senior Data Engineer
Current• Provided a solution using HIVE, and SQOOP (to export/ import data), for faster data load by replacing the traditional ETL process with HDFS for loading data to target tables. • Develop framework for converting existing PowerCenter mappings and to PySpark (Python and Spark) Jobs. • Developed complex data cleaning and transformation logic using PySpark on AWS Glue to process unstructured data from S3 into analytics-ready datasets in Redshift.• Created serverless ETL workflows in a cloud platform using AWS Glue, Glue Data Catalog, S3, RDS, Cloud Watch, and Lambda.• Using Scala to compare the performance of Spark with Map Reduce, Hive• Developed the Pig UDFs to preprocess the data for analysis.• Implemented pipeline to load XML into HDFS using STORM & FLINK.• Used Pig Latin and Pyspark scripts to extract the data from the output files, process it, and load it into HDFS.• Worked on Creating Custom Datasets for downstream reporting.• Implemented partitioning, dynamic partitions, and bucketing in HIVE.• Used the messaging Framework Kafka.• Provide guidance to development team working on PySpark as ETL platform• Implemented configuration and optimization techniques for Redshift clusters to maximize data processing performance and streamline query execution, resulting in high-performance data analytics capabilities• Optimize the Pyspark jobs to run on Kubernetes Cluster for faster data processing.• Implemented AWS Athena for ad-hoc data analysis and querying on data stored in AWS S3• Used Kafka with a combination of Apache Storm, Hive for real-time analysis of streaming of data.• Utilized AWS CloudWatch to monitor and handle resources, configure alarms, and gather metrics• Configured Spark streaming to receive real-time data from the Kafka and store the stream data to HDFS.• Creating Databricks notebooks using SQL, Python • Used Data formats like ORC, Avro, Parquet.