@SuppressWarnings({})
    public synchronized void streamingPut(ByteArray key, Versioned<byte[]> value) {

        if(MARKED_BAD) {
            logger.error("Cannot stream more entries since Recovery Callback Failed!");
            throw new VoldemortException("Cannot stream more entries since Recovery Callback Failed!");
        }

        for(String store: storeNames) {
            streamingPut(key, value, store);
        }

    }
@ SuppressWarnings ( { } ) public synchronized void streamingPut ( ByteArray key , Versioned < byte [ ] > value ) { if ( MARKED_BAD ) { logger . error ( "Cannot stream more entries since Recovery Callback Failed!" ) ; throw new VoldemortException ( "Cannot stream more entries since Recovery Callback Failed!" ) ; } for ( String store : storeNames ) { streamingPut ( key , value , store ) ; } }
A Streaming Put call
*
@param key - The key

@param value - The value