Voglio calcolare la differenza dato un flusso bidirezionale di numeri usando l'elaborazione del flusso. Sto pensando di usare Apache Spark o una tecnologia simile.
Per dirla in modo più concreto, la Banca A invia denaro alla Banca B e la Banca B invia denaro alla Banca A per tutto il giorno in modo tale che in qualsiasi momento vogliamo calcolare la differenza per scoprire chi deve chi e quanto ?
L'Algorithm può semplicemente interrompere la corrente in piccoli intervalli e calcolare la differenza in ogni intervallo di tempo e sommare i risultati di ciascun intervallo di tempo (supponendo che i numeri in un intervallo non si sovrappongano ad altri intervalli).
Vorrei sapere qual è il modo migliore per raggiungere questo obiettivo? Sono aperto anche a qualsiasi altro suggerimento nell'algoritmo.