Senior Data Engineer
Current• Experience in data transformations using Map-Reduce, HIVE for different file formats.• Involved in converting Hive/SQL queries into transformations using Python• Performed complex joins on tables in hive with various optimization techniques• Designed 3NF data models for ODS, OLTP systems and dimensional data models using Star and Snowflake Schemas• Worked on Snowflake environment to remove redundancy and load real time data from various data sources into HDFS using Kafka• Developed data warehouse model in Snowflake for over 100 datasets• Designing and implementing a fully operational production grade large scale data solution on Snowflake Data Warehouse• Work with structured/semi-structured data ingestion and processing on AWS using S3, Python. Migrate on-premises big data workloads to AWS• Designed the data aggregations on Hive for ETL processing on Amazon EMR to process data as per business requirement• Involved in migration of data from existing RDBMS to Hadoop using Sqoop for processing data, evaluate performance of various algorithms/models/strategies based on real-world data sets• Designed and configured Kafka cluster to accommodate heavy throughput of 1 million messages per second. Used Kafka producer 0.6.3 API's to produce messages• Extract Real time feed using Kafka and Spark Streaming and convert it to RDD and process data in the form of Data Frame and save the data as Parquet format in HDFS• Used Kafka and Kafka brokers, initiated the spark context and processed live streaming information with RDD and Used Kafka to load data into HDFS and NoSQL databases.• Subscribing the Kafka topic with Kafka consumer client and process the events in real time using spark.• Development of Spark structured streaming to read the data from Kafka in real time and batch modes, apply different mode of Change data captures (CDCs) and then load the data into Hive