(String table, String key,
HashMap<String, ByteIterator> values)
| 88 | } |
| 89 | |
| 90 | @Override |
| 91 | public int update(String table, String key, |
| 92 | HashMap<String, ByteIterator> values) { |
| 93 | Iterator<String> keys = values.keySet().iterator(); |
| 94 | HashMap<String, byte[]> map = new HashMap<>(); |
| 95 | while (keys.hasNext()) { |
| 96 | String field = keys.next(); |
| 97 | map.put(field, values.get(field).toArray()); |
| 98 | } |
| 99 | YCSBMessage msg = YCSBMessage.newUpdateRequest(table, key, map); |
| 100 | byte[] reply = proxy.invokeOrdered(msg.getBytes()); |
| 101 | YCSBMessage replyMsg = YCSBMessage.getObject(reply); |
| 102 | return replyMsg.getResult(); |
| 103 | } |
| 104 | |
| 105 | } |
no test coverage detected