org.apache.paimon.table.query

Class LocalTableQuery

java.lang.Object

org.apache.paimon.table.query.LocalTableQuery

All Implemented Interfaces:

Closeable, AutoCloseable, TableQuery

public class LocalTableQuery
extends Object
implements TableQuery

Implementation for TableQuery for caching data and file in local.

Constructor Summary

Constructors

Constructor and Description
LocalTableQuery(FileStoreTable table)

Method Summary

Modifier and Type	Method and Description
void	close()
InternalRowSerializer	createValueSerializer()
InternalRow	lookup(BinaryRow partition, int bucket, InternalRow key) TODO remove synchronized and supports multiple thread to lookup.
void	refreshFiles(BinaryRow partition, int bucket, List<DataFileMeta> beforeFiles, List<DataFileMeta> dataFiles)
LocalTableQuery	withCacheRowFilter(Filter<InternalRow> cacheRowFilter)
LocalTableQuery	withIOManager(IOManager ioManager)
LocalTableQuery	withValueProjection(int[] projection)

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalTableQuery

public LocalTableQuery(FileStoreTable table)

Method Detail

refreshFiles

public void refreshFiles(BinaryRow partition,
                         int bucket,
                         List<DataFileMeta> beforeFiles,
                         List<DataFileMeta> dataFiles)

lookup

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

TODO remove synchronized and supports multiple thread to lookup.

Specified by:

lookup in interface TableQuery

Throws:

IOException

withValueProjection

public LocalTableQuery withValueProjection(int[] projection)

Specified by:

withValueProjection in interface TableQuery

withIOManager

public LocalTableQuery withIOManager(IOManager ioManager)

withCacheRowFilter

public LocalTableQuery withCacheRowFilter(Filter<InternalRow> cacheRowFilter)

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