public Map<K, List<Versioned<V>>> getAllWithCustomTimeout(CompositeVoldemortRequest<K, V> requestWrapper) {
        validateTimeout(requestWrapper.getRoutingTimeoutInMs());
        Map<K, List<Versioned<V>>> items = null;
        for(int attempts = 0;; attempts++) {
            if(attempts >= this.metadataRefreshAttempts)
                throw new VoldemortException(this.metadataRefreshAttempts
                                             + " metadata refresh attempts failed.");
            try {
                String KeysHexString = "";
                long startTimeInMs = System.currentTimeMillis();
                if(logger.isDebugEnabled()) {
                    Iterable<ByteArray> keys = (Iterable<ByteArray>) requestWrapper.getIterableKeys();
                    KeysHexString = getKeysHexString(keys);
                    debugLogStart("GET_ALL",
                                  requestWrapper.getRequestOriginTimeInMs(),
                                  startTimeInMs,
                                  KeysHexString);
                }
                items = store.getAll(requestWrapper);
                if(logger.isDebugEnabled()) {
                    int vcEntrySize = 0;

                    for(List<Versioned<V>> item: items.values()) {
                        for(Versioned<V> vc: item) {
                            vcEntrySize += ((VectorClock) vc.getVersion()).getVersionMap().size();
                        }
                    }

                    debugLogEnd("GET_ALL",
                                requestWrapper.getRequestOriginTimeInMs(),
                                startTimeInMs,
                                System.currentTimeMillis(),
                                KeysHexString,
                                vcEntrySize);
                }
                return items;
            } catch(InvalidMetadataException e) {
                logger.info("Received invalid metadata exception during getAll [  "
                            + e.getMessage() + " ] on store '" + storeName + "'. Rebootstrapping");
                bootStrap();
            }
        }
    }
public Map < K , List < Versioned < V > > > getAllWithCustomTimeout ( CompositeVoldemortRequest < K , V > requestWrapper ) { validateTimeout ( requestWrapper . getRoutingTimeoutInMs ( ) ) ; Map < K , List < Versioned < V > > > items = null ; for ( int attempts = 0 ; ; attempts ++ ) { if ( attempts >= this . metadataRefreshAttempts ) throw new VoldemortException ( this . metadataRefreshAttempts + " metadata refresh attempts failed." ) ; try { String KeysHexString = "" ; long startTimeInMs = System . currentTimeMillis ( ) ; if ( logger . isDebugEnabled ( ) ) { Iterable < ByteArray > keys = ( Iterable < ByteArray > ) requestWrapper . getIterableKeys ( ) ; KeysHexString = getKeysHexString ( keys ) ; debugLogStart ( "GET_ALL" , requestWrapper . getRequestOriginTimeInMs ( ) , startTimeInMs , KeysHexString ) ; } items = store . getAll ( requestWrapper ) ; if ( logger . isDebugEnabled ( ) ) { int vcEntrySize = 0 ; for ( List < Versioned < V > > item : items . values ( ) ) { for ( Versioned < V > vc : item ) { vcEntrySize += ( ( VectorClock ) vc . getVersion ( ) ) . getVersionMap ( ) . size ( ) ; } } debugLogEnd ( "GET_ALL" , requestWrapper . getRequestOriginTimeInMs ( ) , startTimeInMs , System . currentTimeMillis ( ) , KeysHexString , vcEntrySize ) ; } return items ; } catch ( InvalidMetadataException e ) { logger . info ( "Received invalid metadata exception during getAll [  " + e . getMessage ( ) + " ] on store '" + storeName + "'. Rebootstrapping" ) ; bootStrap ( ) ; } } }
Performs a get all operation with the specified composite request object

@param requestWrapper Composite request object containing a reference to
the Iterable keys

@return Map of the keys to the corresponding versioned values