@ Override public void storeAll ( Map mapEntries ) { int batchSize = getBatchSize ( ) ; if ( batchSize == 0 || mapEntries . size ( ) < batchSize ) { storeBatch ( mapEntries ) ; } else { Map batch = new HashMap ( batchSize ) ; while ( ! mapEntries . isEmpty ( ) ) { Iterator iter = mapEntries . entrySet ( ) . iterator ( ) ; while ( iter . hasNext ( ) && batch . size ( ) < batchSize ) { Map . Entry entry = ( Map . Entry ) iter . next ( ) ; batch . put ( entry . getKey ( ) , entry . getValue ( ) ) ; } storeBatch ( batch ) ; mapEntries . keySet ( ) . removeAll ( batch . keySet ( ) ) ; batch . clear ( ) ; } } }
Persist all entries from the specified map into the data store .