RankedSet { public static ConfigBuilder newConfigBuilder() { return new ConfigBuilder(); } RankedSet(Subspace subspace, Executor executor, Config config);  RankedSet(Subspace subspace, Executor executor, HashFunction hashFunction, int nlevels);  RankedSet(Subspace subspace, Executor executor, int nlevels);  RankedSet(Subspace subspace, Executor executor); static ConfigBuilder newConfigBuilder(); CompletableFuture<Void> init(TransactionContext tc); CompletableFuture<Boolean> initNeeded(ReadTransactionContext tc); CompletableFuture<Boolean> add(TransactionContext tc, byte[] key); CompletableFuture<Boolean> remove(TransactionContext tc, byte[] key); CompletableFuture<Void> clear(TransactionContext tc); CompletableFuture<Boolean> contains(ReadTransactionContext tc, byte[] key); CompletableFuture<Long> count(ReadTransactionContext tc, byte[] key); CompletableFuture<byte[]> getNth(ReadTransactionContext tc, long rank); List<byte[]> getRangeList(ReadTransactionContext tc, byte[] beginKey, byte[] endKey); AsyncIterable<byte[]> getRange(ReadTransaction tr, byte[] beginKey, byte[] endKey); CompletableFuture<Void> preloadForLookup(ReadTransaction tr); CompletableFuture<Long> rank(ReadTransactionContext tc, byte[] key); CompletableFuture<Long> rank(ReadTransactionContext tc, byte[] key, boolean nullIfMissing); CompletableFuture<Long> size(ReadTransactionContext tc); static final HashFunction JDK_ARRAY_HASH; static final HashFunction CRC_HASH; static final HashFunction RANDOM_HASH; static final HashFunction DEFAULT_HASH_FUNCTION; static final int MAX_LEVELS; static final int DEFAULT_LEVELS; static final Config DEFAULT_CONFIG; }
@Test @Tag(Tags.Slow) public void randomFiveThreadsWithDuplicates() throws InterruptedException { config = RankedSet.newConfigBuilder().setCountDuplicates(true).build(); randomFiveThreads(); }