public void transferAllStateDataToDirectory ( IncrementalRemoteKeyedStateHandle restoreStateHandle , Path dest , CloseableRegistry closeableRegistry ) throws Exception { final Map < StateHandleID , StreamStateHandle > sstFiles = restoreStateHandle . getSharedState ( ) ; final Map < StateHandleID , StreamStateHandle > miscFiles = restoreStateHandle . getPrivateState ( ) ; downloadDataForAllStateHandles ( sstFiles , dest , closeableRegistry ) ; downloadDataForAllStateHandles ( miscFiles , dest , closeableRegistry ) ; }
Transfer all state data to the target directory using specified number of threads .