question: @ Override public void endOfStream ( ) throws AdeException , AdeFlowException { for ( Entry < String , PerodicityBounder > last : m_lastSeen . entrySet ( ) ) { final PerodicityBounder pb = last . getValue ( ) ; pb . train ( last . getKey ( ) ) ; } m_trained = true ; }
target:  At the end of the stream, get all the message ids and run a train for each message id.