MCPcopy Index your code
hub / github.com/OpenTSDB/opentsdb / flushCollisions

Method flushCollisions

test/tree/TestTree.java:248–258  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

246 }
247
248 @Test
249 public void flushCollisions() throws Exception {
250 setupStorage(true, true);
251 final Tree tree = buildTestTree();
252 tree.setStoreFailures(true);
253 tree.addCollision("010203", "AABBCCDD");
254 assertNotNull(tree.flushCollisions(storage.getTSDB())
255 .joinUninterruptibly());
256 assertEquals(4, storage.numRows(TREE_TABLE));
257 assertEquals(3, storage.numColumns(TREE_TABLE, new byte[] { 0, 1, 1 }));
258 }
259
260 @Test
261 public void flushCollisionsDisabled() throws Exception {

Callers

nothing calls this directly

Calls 8

setupStorageMethod · 0.95
buildTestTreeMethod · 0.95
setStoreFailuresMethod · 0.95
addCollisionMethod · 0.95
flushCollisionsMethod · 0.95
getTSDBMethod · 0.80
numRowsMethod · 0.80
numColumnsMethod · 0.80

Tested by

no test coverage detected