Ganesh Kumar Valiveti

Senior Prescription Drug Assistance Program

Built metrics and report generation scripts using PySpark for seamless integration into ETL pipelines.

Reconciliation Report

Design and Rewrite scripts for reconciliation report generation from old-style Shell Script, Scala and Python combo to PySpark and extend the same for generic implementations, which are used for billing purposes.

Create Cloudwatch dashboards and alarms for alert creation.

Consistent Patient Store (CPS) Analytics

Onboarding new tenants to transmit data from the Source to Analytics platform so that provider-specific dashboards can be embedded in the Source/Tenant portal.

Interoperability

Designed and built a platform to support Interoperability data in health care, the pipelines are based on Lambda Architecture to handle both batch and Streaming processing.

Enhancement of Rundeck scheduler jobs for interoperability from existing scheduled times.

File Processing Status – Send the status of each file for success/failure to the customer.

Airflow Migration

Data pipeline orchestration migration from Rundeck scheduler (Shell Scripts) into Apache Airflow (Python Scripts).

COVID-19 Passport

Designed a spark hourly batch pipeline based on Lambda Architecture and efficiently amalgamated multiple data points to form a single view.

Referral Navigator Pipeline

The objective of the referral navigator pipeline is to ingest referral events, de-normalize nested JSON to tabular form and save it as parquet to run daily using Delta Lake.

Common well

Common well to be used for referential matching services. Job creation and integration with upstream and downstream.

Accolade

Accolade is a patient advocate/navigator whose principal customers are self-insured employers, whereas Accolade must currently assist their member community, it would be hugely beneficial to be able to reach out to an Accolade member before the episode of care occurs. Thus Accolade is looking to receive notification whenever one of their members has an eligibility request/response sent through a CHC Clearing House to one of their self-insured payer customers.

Transaction Volume and Billing Report - Create a report of time metrics for each request and response for each eligibility transaction to be sent daily to the customer for the previous day's data.

Health App

Enhance configuration files of existing individual tables to integrate into a single configuration file to reduce maintenance and ci/cd process.

Enhance UDFs for new customer requirements to support different output formats

Data availability checks from the scheduler before creating an EMR cluster for running pipeline for Databases, s3 Paths and FTP.

Normalization using Smarty streets API for checking User Addresses of US Locations and tracking the success/failure state of each address as a separate table for easy analysis.

Data pipeline orchestration with Rundeck scheduler using Shell Scripting.

CNAD

Worked on Spark SQL to fetch data from HDFS and run in Spark.

Oozie Workflow design and orchestration for running Spark- Scala job flow and python scripts.

Worked on Report generation based on requirements using Spark/Scala, AWS and Airflow with python scripting.

Build automation and dependency management using Maven, and Gradle for packaging, testing, and deploying Spark and Java-based applications.

Pocket Piece

Created an automated email that provides reprocessed record information to the clients.

Created Tibco job setup to run the jobs as part of the orchestration framework.

BNAD

Serverless Infrastructure provisioning for EMR builds from a Local Machine to eliminate the usage of Ansible.

Worked on deploying Jenkins through Docker on an EC2 Instance.

Jenkins adoption for continual CI/CD process implementation.

Designed and orchestrated Airflow workflows for STAF Integration using Terraform and created the pipelines and DAGs with Python for Scripting.