public abstract class AbstractMutableHashTable<T> extends Object
Modifier and Type | Field and Description |
---|---|
protected TypeComparator<T> |
buildSideComparator
The utilities to hash and compare the build side data types.
|
protected TypeSerializer<T> |
buildSideSerializer
The utilities to serialize the build side data types.
|
protected boolean |
closed
Flag to mark the table as open / closed.
|
protected Object |
stateLock
The lock to synchronize state changes (open / close) on
|
Constructor and Description |
---|
AbstractMutableHashTable(TypeSerializer<T> buildSideSerializer,
TypeComparator<T> buildSideComparator) |
Modifier and Type | Method and Description |
---|---|
abstract void |
abort() |
abstract void |
close()
Closes the hash table.
|
TypeComparator<T> |
getBuildSideComparator() |
TypeSerializer<T> |
getBuildSideSerializer() |
abstract MutableObjectIterator<T> |
getEntryIterator() |
abstract List<MemorySegment> |
getFreeMemory() |
abstract <PT> AbstractHashTableProber<PT,T> |
getProber(TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,T> pairComparator) |
abstract void |
insert(T record) |
abstract void |
insertOrReplaceRecord(T record) |
abstract void |
open()
Initialize the hash table
|
protected final TypeSerializer<T> buildSideSerializer
protected final TypeComparator<T> buildSideComparator
protected final Object stateLock
protected boolean closed
public AbstractMutableHashTable(TypeSerializer<T> buildSideSerializer, TypeComparator<T> buildSideComparator)
public TypeSerializer<T> getBuildSideSerializer()
public TypeComparator<T> getBuildSideComparator()
public abstract void open()
public abstract void close()
public abstract void abort()
public abstract List<MemorySegment> getFreeMemory()
public abstract void insert(T record) throws IOException
IOException
public abstract void insertOrReplaceRecord(T record) throws IOException
IOException
public abstract MutableObjectIterator<T> getEntryIterator()
public abstract <PT> AbstractHashTableProber<PT,T> getProber(TypeComparator<PT> probeSideComparator, TypePairComparator<PT,T> pairComparator)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.