| Package | Description |
|---|---|
| org.apache.paimon.flink.query | |
| org.apache.paimon.service.server | |
| org.apache.paimon.table.query |
| Modifier and Type | Class and Description |
|---|---|
class |
RemoteTableQuery
Implementation for
TableQuery to lookup data from remote service. |
| Constructor and Description |
|---|
KvQueryServer(int serverId,
int numServers,
String bindAddress,
Iterator<Integer> bindPortIterator,
Integer numEventLoopThreads,
Integer numQueryThreads,
TableQuery lookup,
ServiceRequestStats stats) |
KvServerHandler(KvQueryServer server,
int serverId,
int numServers,
TableQuery lookup,
MessageSerializer<KvRequest,KvResponse> serializer,
ServiceRequestStats stats)
Create the handler used by the
KvQueryServer. |
| Modifier and Type | Class and Description |
|---|---|
class |
LocalTableQuery
Implementation for
TableQuery for caching data and file in local. |
| Modifier and Type | Method and Description |
|---|---|
default TableQuery |
TableQuery.withValueProjection(int[] projection) |
TableQuery |
TableQuery.withValueProjection(int[][] projection) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.