@ Override public void publishData ( Collection < ? extends WorkUnitState > states ) throws IOException { for ( WorkUnitState state : states ) { if ( state . getWorkingState ( ) == WorkUnitState . WorkingState . SUCCESSFUL ) { state . setWorkingState ( WorkUnitState . WorkingState . COMMITTED ) ; log . info ( "Marking state committed" ) ; } } }
Publish the data for the given tasks .