Herramientas de código abierto para obtener ayuda en el flujo de minería de puntajes de la tabla de líderes

Considere una secuencia que contiene tuplas que (user, new_score) representan las puntuaciones de los usuarios en un juego en línea. La transmisión podría tener 100-1,000 elementos nuevos por segundo. El juego tiene 200K a 300K jugadores únicos. Me gustaría tener algunas consultas permanentes...