@Test public void testPuttingBackChunksAfterFlushing() throws UnexpectedStateException { byte[] row = Bytes.toBytes("testrow"); byte[] fam = Bytes.toBytes("testfamily"); byte[] qf1 = Bytes.toBytes("testqualifier1"); byte[] qf2 = Bytes.toBytes("testqualifier2"); byte[] qf3 = Bytes.toBytes("testqualifier3"); byte[] qf4 = Bytes.toBytes("testqualifier4"); byte[] qf5 = Bytes.toBytes("testqualifier5"); byte[] val = Bytes.toBytes("testval"); DefaultMemStore memstore = new DefaultMemStore(); memstore.add(new KeyValue(row, fam, qf1, val)); memstore.add(new KeyValue(row, fam, qf2, val)); memstore.add(new KeyValue(row, fam, qf3, val)); MemStoreSnapshot snapshot = memstore.snapshot(); assertEquals(3, memstore.snapshot.size()); assertEquals(0, memstore.kvset.size()); memstore.add(new KeyValue(row, fam, qf4, val)); memstore.add(new KeyValue(row, fam, qf5, val)); assertEquals(2, memstore.kvset.size()); memstore.clearSnapshot(snapshot.getId()); int chunkCount = chunkPool.getPoolSize(); assertTrue(chunkCount > 0); }
int getPoolSize() { return this.reclaimedChunks.size(); }
MemStoreChunkPool { int getPoolSize() { return this.reclaimedChunks.size(); } }
MemStoreChunkPool { int getPoolSize() { return this.reclaimedChunks.size(); } MemStoreChunkPool(Configuration conf, int chunkSize, int maxCount,
      int initialCount); }
MemStoreChunkPool { int getPoolSize() { return this.reclaimedChunks.size(); } MemStoreChunkPool(Configuration conf, int chunkSize, int maxCount,
      int initialCount);  }
MemStoreChunkPool { int getPoolSize() { return this.reclaimedChunks.size(); } MemStoreChunkPool(Configuration conf, int chunkSize, int maxCount,
      int initialCount);   }