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.