@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;
}

@ 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 ; }
at the end of the stream , get all the message ids and run a train for each message id .
