org.apache.paimon.service.client

Class KvQueryClient

java.lang.Object

org.apache.paimon.service.client.KvQueryClient

public class KvQueryClient
extends Object

A class for the Client to get values from Servers.

Constructor Summary

Constructors

Constructor and Description
KvQueryClient(QueryLocation queryLocation, int numEventLoopThreads)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<BinaryRow[]>	getValues(BinaryRow partition, int bucket, BinaryRow[] keys)
void	shutdown()
CompletableFuture<Void>	shutdownFuture()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KvQueryClient

public KvQueryClient(QueryLocation queryLocation,
                     int numEventLoopThreads)

Method Detail

getValues

public CompletableFuture<BinaryRow[]> getValues(BinaryRow partition,
                                                int bucket,
                                                BinaryRow[] keys)

shutdown

public void shutdown()

shutdownFuture

public CompletableFuture<Void> shutdownFuture()