public class LocalTableQuery extends Object implements TableQuery
TableQuery
for caching data and file in local.Constructor and Description |
---|
LocalTableQuery(FileStoreTable table) |
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) |
public LocalTableQuery(FileStoreTable table)
public void refreshFiles(BinaryRow partition, int bucket, List<DataFileMeta> beforeFiles, List<DataFileMeta> dataFiles)
@Nullable public InternalRow lookup(BinaryRow partition, int bucket, InternalRow key) throws IOException
lookup
in interface TableQuery
IOException
public LocalTableQuery withValueProjection(int[] projection)
withValueProjection
in interface TableQuery
public LocalTableQuery withIOManager(IOManager ioManager)
public LocalTableQuery withCacheRowFilter(Filter<InternalRow> cacheRowFilter)
public InternalRowSerializer createValueSerializer()
createValueSerializer
in interface TableQuery
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.