public abstract class FullCacheLookupTable extends Object implements LookupTable
Modifier and Type | Class and Description |
---|---|
static class |
FullCacheLookupTable.Context
Context for
LookupTable . |
static interface |
FullCacheLookupTable.TableBulkLoader
Bulk loader for the table.
|
Modifier and Type | Field and Description |
---|---|
protected int |
appendUdsFieldNumber |
protected FullCacheLookupTable.Context |
context |
protected Object |
lock |
protected RowType |
projectedType |
protected boolean |
refreshAsync |
protected RocksDBStateFactory |
stateFactory |
protected FieldsComparator |
userDefinedSeqComparator |
Constructor and Description |
---|
FullCacheLookupTable(FullCacheLookupTable.Context context) |
Modifier and Type | Method and Description |
---|---|
protected void |
bootstrap() |
void |
close() |
abstract FullCacheLookupTable.TableBulkLoader |
createBulkLoader() |
List<InternalRow> |
get(InternalRow key) |
abstract List<InternalRow> |
innerGet(InternalRow key) |
protected void |
openStateFactory() |
Predicate |
projectedPredicate() |
void |
refresh() |
void |
refresh(Iterator<InternalRow> input) |
protected abstract void |
refreshRow(InternalRow row,
Predicate predicate) |
void |
specificPartitionFilter(Predicate filter) |
void |
specifyCacheRowFilter(Filter<InternalRow> filter) |
abstract byte[] |
toKeyBytes(InternalRow row) |
abstract byte[] |
toValueBytes(InternalRow row) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
open
protected final Object lock
protected final FullCacheLookupTable.Context context
protected final RowType projectedType
protected final boolean refreshAsync
@Nullable protected final FieldsComparator userDefinedSeqComparator
protected final int appendUdsFieldNumber
protected RocksDBStateFactory stateFactory
public FullCacheLookupTable(FullCacheLookupTable.Context context)
public void specificPartitionFilter(Predicate filter)
specificPartitionFilter
in interface LookupTable
public void specifyCacheRowFilter(Filter<InternalRow> filter)
specifyCacheRowFilter
in interface LookupTable
public void refresh() throws Exception
refresh
in interface LookupTable
Exception
public final List<InternalRow> get(InternalRow key) throws IOException
get
in interface LookupTable
IOException
public void refresh(Iterator<InternalRow> input) throws IOException
IOException
public abstract List<InternalRow> innerGet(InternalRow key) throws IOException
IOException
protected abstract void refreshRow(InternalRow row, Predicate predicate) throws IOException
IOException
public abstract byte[] toKeyBytes(InternalRow row) throws IOException
IOException
public abstract byte[] toValueBytes(InternalRow row) throws IOException
IOException
public abstract FullCacheLookupTable.TableBulkLoader createBulkLoader()
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.