org.apache.paimon.flink.query

Class RemoteTableQuery

java.lang.Object

org.apache.paimon.flink.query.RemoteTableQuery

All Implemented Interfaces:

Closeable, AutoCloseable, TableQuery

public class RemoteTableQuery
extends Object
implements TableQuery

Implementation for TableQuery to lookup data from remote service.

Constructor Summary

Constructors

Constructor and Description
RemoteTableQuery(Table table)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	cancel()
void	close()
InternalRowSerializer	createValueSerializer()
static boolean	isRemoteServiceAvailable(FileStoreTable table)
InternalRow	lookup(BinaryRow partition, int bucket, InternalRow key)
RemoteTableQuery	withValueProjection(int[] projection)
RemoteTableQuery	withValueProjection(int[][] projection)

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteTableQuery

public RemoteTableQuery(Table table)

Method Detail

isRemoteServiceAvailable

public static boolean isRemoteServiceAvailable(FileStoreTable table)

lookup

@Nullable
public InternalRow lookup(BinaryRow partition,
                                    int bucket,
                                    InternalRow key)
                             throws IOException

Specified by:

lookup in interface TableQuery

Throws:

IOException

withValueProjection

public RemoteTableQuery withValueProjection(int[] projection)

Specified by:

withValueProjection in interface TableQuery

withValueProjection

public RemoteTableQuery withValueProjection(int[][] projection)

Specified by:

withValueProjection in interface TableQuery

createValueSerializer

public InternalRowSerializer createValueSerializer()

Specified by:

createValueSerializer in interface TableQuery

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

cancel

@VisibleForTesting
public CompletableFuture<Void> cancel()