@ SuppressWarnings ( { } ) public synchronized void removeStoreFromSession ( List < String > storeNameToRemove ) { logger . info ( "closing the Streaming session for a few stores" ) ; commitToVoldemort ( storeNameToRemove ) ; cleanupSessions ( storeNameToRemove ) ; }
Remove a list of stores from the session