@ Override public void preSave ( String checkpointId ) { System . out . println ( String . format ( "Saving spout state at checkpoint %s" , checkpointId ) ) ; }
These two methods are required to implement the IStatefulComponent interface