public class KvQueryClient extends Object
Constructor and Description |
---|
KvQueryClient(QueryLocation queryLocation,
int numEventLoopThreads) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<BinaryRow[]> |
getValues(BinaryRow partition,
int bucket,
BinaryRow[] keys) |
void |
shutdown() |
CompletableFuture<Void> |
shutdownFuture() |
public KvQueryClient(QueryLocation queryLocation, int numEventLoopThreads)
public CompletableFuture<BinaryRow[]> getValues(BinaryRow partition, int bucket, BinaryRow[] keys)
public void shutdown()
public CompletableFuture<Void> shutdownFuture()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.