org.apache.flink.runtime.operators.hash

Class AbstractMutableHashTable<T>

java.lang.Object

org.apache.flink.runtime.operators.hash.AbstractMutableHashTable<T>

Direct Known Subclasses:

CompactingHashTable

public abstract class AbstractMutableHashTable<T>
extends Object

Field Summary

Fields

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.

Constructor Summary

Constructors

Constructor and Description
AbstractMutableHashTable(TypeSerializer<T> buildSideSerializer, TypeComparator<T> buildSideComparator)

Method Summary

Modifier and Type	Method and Description
abstract void	abort()
abstract void	close()
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()

Methods inherited from class java.lang.Object

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

Field Detail

buildSideSerializer

protected final TypeSerializer<T> buildSideSerializer

The utilities to serialize the build side data types.

buildSideComparator

protected final TypeComparator<T> buildSideComparator

The utilities to hash and compare the build side data types.

Constructor Detail

AbstractMutableHashTable

public AbstractMutableHashTable(TypeSerializer<T> buildSideSerializer,
                                TypeComparator<T> buildSideComparator)

Method Detail

getBuildSideSerializer

public TypeSerializer<T> getBuildSideSerializer()

getBuildSideComparator

public TypeComparator<T> getBuildSideComparator()

open

public abstract void open()

close

public abstract void close()

abort

public abstract void abort()

getFreeMemory

public abstract List<MemorySegment> getFreeMemory()

insert

public abstract void insert(T record)
                     throws IOException

Throws:

IOException

insertOrReplaceRecord

public abstract void insertOrReplaceRecord(T record)
                                    throws IOException

Throws:

IOException

getEntryIterator

public abstract MutableObjectIterator<T> getEntryIterator()

getProber

public abstract <PT> AbstractHashTableProber<PT,T> getProber(TypeComparator<PT> probeSideComparator,
                                                             TypePairComparator<PT,T> pairComparator)