code: @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);
          }
  
      }
docs: A Streaming Put call
  *
  @param key - The key
  
  @param value - The value