Senior Bigdata Developer
CurrentProject OverviewSearch BigData system consist of various features including indexing pipeline, ETL process, signalpipeline and analytics pipeline. This system manages all data for Merch Modules, Lefthandnavigation, Polaris cloud query creation, Spellcheck, Highlight, and various other search businesslogic.Role and Responsibilities• Implement ETL job using Python to process user behavior data including clicking, check-out and query on Walmart site and load those data into HIVE tables after doing respectiveaggregation.• Implement NRT processor with Spark to generate index document.• Implement python job to generate different signal and persist the results into K-V store.• Migrate job to Airflow for dynamic pipeline generation and higher scalability and bettermonitoring as well.• Come up with Dashboard on Graphana for the purpose of monitoring the status of pipelines.• Implement python job to trigger Spark batch job to download product information from Cassandra DB.• Implement processor to consume the frequently updated product/item event from Kafka topicand update the index accordingly and persist it into Cassandra database.• Persist the Kafka event log into ElasticSearch and generate dashboard on Kibana for monitoring and analytics.