Outils opensource pour aider à extraire le flux de scores des classements

Considérez un flux contenant des tuples (user, new_score) représentant les scores des utilisateurs dans un jeu en ligne. Le flux pourrait contenir de 100 à 1 000 nouveaux éléments par seconde. Le jeu a 200K à 300K joueurs uniques. J'aimerais avoir des requêtes permanentes comme: Quels joueurs ont...