(String table, String key,
Set<String> fields, HashMap<String, ByteIterator> result)
| 72 | } |
| 73 | |
| 74 | @Override |
| 75 | public int read(String table, String key, |
| 76 | Set<String> fields, HashMap<String, ByteIterator> result) { |
| 77 | HashMap<String, byte[]> results = new HashMap<>(); |
| 78 | YCSBMessage request = YCSBMessage.newReadRequest(table, key, fields, results); |
| 79 | byte[] reply = proxy.invokeUnordered(request.getBytes()); |
| 80 | YCSBMessage replyMsg = YCSBMessage.getObject(reply); |
| 81 | return replyMsg.getResult(); |
| 82 | } |
| 83 | |
| 84 | @Override |
| 85 | public int scan(String arg0, String arg1, int arg2, Set<String> arg3, |
no test coverage detected