Apache Spark Experts in Hamburg

• Building an AI & Data Consultancy Practice with the goal of helping European companies adopt Artificial Intelligence and modern data platforms
• End-to-end further development of a production system using modified coding agents (OpenCode). Tech stack: Kubernetes, Argo, Keycloak, Typescript, Grafana, GitOps, DevOps, Playwright
• Internal research project on the use of coding agents in the field of mathematical logic for creating formal models. Use of Cursor IDE and Codex, Codex CLI. Architecture design, quality control and refactoring, as well as writing code and tests. Repository (open source) available pre-launch
• Research on the role of mathematical logic as a formal language that connects IT and AI with business processes
• Project lead for collecting and deploying parking recommendations for rail vehicles with significant savings potential based on real-time data in a mobility and transport company
• Project lead for collecting and distributing process measurement points for real-time control in a mobility and transport company
• Deputy application owner for an app used for communication in the dispatching and provision of rail vehicles

traigo is VTG's digital rail logistics and fleet management platform. It processes large volumes of telemetry, mileage, geofence, sensor and wagon-movement events in near real time and provides operational services for rail logistics customers across Europe.

As part of Team Customer Selfcare, I worked on the design, implementation, optimisation and operation of large-scale backend services and event-driven processing pipelines — covering both feature development and operational ownership of business-critical production systems. I also regularly acted as first responder for production incidents, data inconsistencies and performance investigations across multiple distributed services.

• Design and implementation of event-driven backend services.
• Migration and replacement of legacy processing pipelines.
• Development of replay / rebuild mechanisms for large event datasets.
• High-throughput asynchronous event processing on SNS / SQS.
• Database and query optimisation for PostgreSQL and DynamoDB.
• Design of scalable read / write models and aggregation pipelines.
• Production troubleshooting and operational support.
• Performance tuning and infrastructure scaling.
• Design and stabilisation of integration and system tests.
• Technical concepts, architecture documentation, and cross-team collaboration.
• Support the further development of existing GitLab CI/CD pipelines

Geofence & Wagon Stay Processing

• Algorithm to detect vehicles within geofences (entry, exit, dwell time).
• Event sourcing with guaranteed chronological order within the affected time window.
• Refactored geofence event and wagon-stay processing logic for performance.
• Resolved race conditions and event-ordering problems in distributed services; server-side filtering, aggregation and optimised query pipelines.
• Repair and replay tooling for corrupted or inconsistent movement data.

Fleet Metadata & Mileage

• Modernised the service; migrated storage from DynamoDB to PostgreSQL to improve traceability and accelerate new features.
• Scalable mileage aggregation and replay mechanisms.
• Read / write models and optimised queries for high-volume mileage calculations.

Sensor & Telematics Integration

• Integrated telemetry and sensor processing pipelines.
• Snapshot and state-calculation logic for sensor systems.
• APIs and persistence models for wagon sensor data; data-quality improvements.
• Further development of a service using gRPC for intra-service communication.

Movement Segment Processing & Routing

• Migrated services to new movement-segment event streams.
• Built replay and rebuild tooling for segment correction.
• Optimised throughput and reliability for high-volume event processing.

Condition Monitoring & Wagon Analytics

• APIs and backend services for wagon condition monitoring.
• Brake-wear prediction processing and wagon analytics functionality.
• PostgreSQL views and optimised query models for operational dashboards.

Operational Reliability - First Responder

• Investigated production incidents and distributed-system failures; DLQ analysis, replay and operational recovery.
• Tuned database performance and AWS infrastructure under production load.
• Improved observability, monitoring and operational tooling.
• Supported rollout strategies, monitoring and post-deployment stabilisation.

• Migration of customer data from a private cloud to AWS
• Optimizing data transformation jobs and migration from Talend to AWS Glue
• Automation of all migration steps
• Used technologies: AWS, Python, Lambda, CloudFormation, SQLServer, AWS Stepfunctions, Glue, PySpark

• Architected and deployed LLM based AI agents, RAG pipelines, and vector search solutions for decision support across retail banking department.
• Developed and shipped robust AI pipelines with guardrails, error handling, monitoring, and fallback logic ensuring high reliability outcomes and compliance with data privacy.
• Developed and deployed ML models to identify transactional anomalies, improving fraud detection and risk assessment in high-volume datasets for credit risk modelling.
• Built, evaluated and fine-tuned ML models to generate propensity scores for customers used to drive personalized targeting campaigns for credit cards and personal finance/loan products.
• Developed an NLP pipeline using BERT embeddings and spaCy NER for SMS/email analysis and customer query logs.
• Trained machine learning models using Isolation Forest to classify user behaviour and detect anomalies.
• Extracted, cleaned, enriched and feature engineered datasets from different sources to build feature stores that powered ML model training.
• Led development of dashboards using Power BI, Grafana, and Prometheus to monitor model performances, KPI trends, and marketing metrics.
• Built multi-touch attribution models using logistic regression and time-decay weights to evaluate lead quality.
• Developed scalable ETL pipelines from CRM, T24, SAP, and ERP, supporting millions of monthly transactions.
• Integrated testing and CI/CD workflows for robust data pipeline deployment.

• Building teams of data people - BI Analysts, Data Scientists, Data Engineers
• Defining data strategy across all business units to support short, mid & long-term business goals
• Collaborating with the product leads & management & heads of departments to provide data support
• Defining budget to make everything happen
• Aligning the data teams goals with company vision, strategy & objectives
• Responsible for the data governance as well as for the strategic development planning
• Defining and developing joint OKRs
• Reporting directly to the CTO & CEO

• Build data pipelines for raw and curated data layers using AWS S3, Glue, Athena, and Lake Formation
• Establish CI/CD using GitHub Actions or GitLab CI with CodePipeline
• Prototype models into demo APIs packaged with Docker, versioned with Git, added basic tests with pytest, and assist deployments on AWS SageMaker Endpoint
• Perform exploratory data analysis and feature engineering with pandas and PySpark; track experiments in MLflow or Weights and Biases
• Design and execute A/B tests to optimize user engagement and drive data-informed decisions

• Attained AWS Certified Cloud Practitioner certification.

• Mastered Rust through self-study, including books, online courses, and open-source contributions.

• Developed a serverless web application using AWS (RDS, Lambda, Polly, Amplify) and TypeScript/React/D3, managed infrastructure with CDK.

• Continuously stayed updated with industry trends through self-education, webinars, and workshops, exploring Data Mesh and FastAPI.

• Built backend APIs using Quarkus, Kotlin, MongoDB, Docker Compose and NGINX
• Developed frontend with React, TypeScript and Ant Design