TerrapinClient { public Future<TerrapinResponse> getMany(String fileSet, Set<ByteBuffer> keyList) { return getManyHelper(fileSet, keyList, true); } TerrapinClient(PropertiesConfiguration configuration,
                        int targetPort,
                        int connectTimeoutMs,
                        int timeoutMs);  TerrapinClient(FileSetViewManager fileSetViewManager,
                        String clusterName,
                        int targetPort,
                        int connectTimeoutMs,
                        int timeoutMs); Future<TerrapinResponse> getManyNoRetries(String fileSet, Set<ByteBuffer> keyList); Future<TerrapinResponse> getMany(String fileSet, Set<ByteBuffer> keyList); Future<TerrapinSingleResponse> getOneNoRetries(String fileSet, ByteBuffer key); Future<TerrapinSingleResponse> getOne(String fileSet, ByteBuffer key);  }
@Test public void testGetMany() throws Exception { TerrapinResponse response = terrapinClient.getManyNoRetries(FILE_SET, (Set) ImmutableSet.of( ByteBuffer.wrap("a".getBytes()), ByteBuffer.wrap("b".getBytes()), ByteBuffer.wrap("c".getBytes()), ByteBuffer.wrap("d".getBytes()), ByteBuffer.wrap("h".getBytes()), ByteBuffer.wrap("i".getBytes()))).get(); Map<ByteBuffer, TerrapinSingleResponse> responseMap = response.getResponseMap(); assertEquals(5, responseMap.size()); checkValue("a", "value_a", responseMap); checkValue("c", "value_c", responseMap); checkValue("d", "value_d", responseMap); checkError("b", TerrapinGetErrorCode.READ_ERROR, responseMap); checkError("h", TerrapinGetErrorCode.OTHER, responseMap); response = terrapinClient.getMany(FILE_SET, (Set) ImmutableSet.of( ByteBuffer.wrap("a".getBytes()), ByteBuffer.wrap("b".getBytes()), ByteBuffer.wrap("c".getBytes()), ByteBuffer.wrap("d".getBytes()), ByteBuffer.wrap("h".getBytes()), ByteBuffer.wrap("i".getBytes()))).get(); responseMap = response.getResponseMap(); assertEquals(5, responseMap.size()); checkValue("a", "value_a", responseMap); checkValue("c", "value_c", responseMap); checkValue("d", "value_d", responseMap); checkValue("b", "value_b", responseMap); checkError("h", TerrapinGetErrorCode.NOT_SERVING_PARTITION, responseMap); }