Merging Embedded Topics with Optimal Transport for Online Topic Modeling on Data Streams

Federica Granese, Benjamin Navet, Serena Villata, Charles Bouveyron
4/10/2025
cs.LGcs.AI

Official code: fgranese/StreamETM (1 star, last commit 2025-06-17).

Abstract

Topic modeling is a key component in unsupervised learning, employed to identify topics within a corpus of textual data. The rapid growth of social media generates an ever-growing volume of textual data daily, making online topic modeling methods essential for managing these data streams that continuously arrive over time. This paper introduces a novel approach to online topic modeling named StreamETM. This approach builds on the Embedded Topic Model (ETM) to handle data streams by merging models learned on consecutive partial document batches using unbalanced optimal transport. Additionally, an online change point detection algorithm is employed to identify shifts in topics over time, enabling the identification of significant changes in the dynamics of text streams. Numerical experiments on simulated and real-world data show StreamETM outperforming competitors. We provide the code publicly available at https://github.com/fgranese/StreamETM.

View on arXivView PDF

Code Implementations(1)

fgranese/StreamETMOfficial100%

Joint European Conference on Machine Learning and Knowledge Discovery in Databases (ECML/PKDD 2025)

10Shell, PythonJun 10, 20251 years agoNOASSERTION
topic-modeling

Similar Papers

Cite this paper

@article{granese2025merging,
  title  = {Merging Embedded Topics with Optimal Transport for Online Topic Modeling on Data Streams},
  author = {Federica Granese and Benjamin Navet and Serena Villata and Charles Bouveyron},
  year   = {2025},
  eprint = {2504.07711},
  archivePrefix = {arXiv},
  url    = {http://arxiv.org/abs/2504.07711v2}
}

Add a badge to your README

Shows whether official code is linked for this paper.

Code of Paper badge
[![Code of Paper](https://codeofpaper.com/badge/2504.07711.svg)](https://codeofpaper.com/paper/2504.07711)

Discussion