Skip to content

Commit

Permalink
Address TDIGEST.INFO changes (#3165)
Browse files Browse the repository at this point in the history
  • Loading branch information
sazzad16 authored Oct 12, 2022
1 parent fb35f0d commit bc0c384
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -32,10 +32,10 @@ private void assertMergedUnmergedNodes(String key, int mergedNodes, int unmerged
assertEquals(Long.valueOf(unmergedNodes), info.get("Unmerged nodes"));
}

private void assertTotalWeight(String key, double totalWeight) {
private void assertTotalWeight(String key, long totalWeight) {
Map<String, Object> info = client.tdigestInfo(key);
assertEquals(totalWeight, Double.parseDouble((String) info.get("Merged weight"))
+ Double.parseDouble((String) info.get("Unmerged weight")), 0.01);
assertEquals(totalWeight, (Long) info.get("Merged weight")
+ (Long) info.get("Unmerged weight"));
}

@Test
Expand Down Expand Up @@ -115,7 +115,7 @@ public void mergeMultiAndParams() {
client.tdigestAdd("from2", weightedValue(1d, 10));

assertEquals("OK", client.tdigestMerge("to", "from1", "from2"));
assertTotalWeight("to", 11d);
assertTotalWeight("to", 11l);

assertEquals("OK", client.tdigestMerge(TDigestMergeParams.mergeParams()
.compression(50).override(), "to", "from1", "from2"));
Expand Down

0 comments on commit bc0c384

Please sign in to comment.