(String table, String key,
HashMap<String, ByteIterator> values)
| 56 | } |
| 57 | |
| 58 | @Override |
| 59 | public int insert(String table, String key, |
| 60 | HashMap<String, ByteIterator> values) { |
| 61 | |
| 62 | Iterator<String> keys = values.keySet().iterator(); |
| 63 | HashMap<String, byte[]> map = new HashMap<>(); |
| 64 | while (keys.hasNext()) { |
| 65 | String field = keys.next(); |
| 66 | map.put(field, values.get(field).toArray()); |
| 67 | } |
| 68 | YCSBMessage msg = YCSBMessage.newInsertRequest(table, key, map); |
| 69 | byte[] reply = proxy.invokeOrdered(msg.getBytes()); |
| 70 | YCSBMessage replyMsg = YCSBMessage.getObject(reply); |
| 71 | return replyMsg.getResult(); |
| 72 | } |
| 73 | |
| 74 | @Override |
| 75 | public int read(String table, String key, |
nothing calls this directly
no test coverage detected