org.apache.flink.runtime.operators.hash

Class AbstractHashTableProber<PT,BT>

java.lang.Object

org.apache.flink.runtime.operators.hash.AbstractHashTableProber<PT,BT>

Type Parameters:

PT - probe side type

BT - build side type

Direct Known Subclasses:

CompactingHashTable.HashTableProber, InPlaceMutableHashTable.HashTableProber

public abstract class AbstractHashTableProber<PT,BT>
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected TypePairComparator<PT,BT>	pairComparator
protected TypeComparator<PT>	probeTypeComparator

Constructor Summary

Constructors

Constructor and Description
AbstractHashTableProber(TypeComparator<PT> probeTypeComparator, TypePairComparator<PT,BT> pairComparator)

Method Summary

Modifier and Type	Method and Description
abstract BT	getMatchFor(PT probeSideRecord)
abstract BT	getMatchFor(PT probeSideRecord, BT targetForMatch)
abstract void	updateMatch(BT record)

Methods inherited from class java.lang.Object

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

Field Detail

probeTypeComparator

protected final TypeComparator<PT> probeTypeComparator

pairComparator

protected final TypePairComparator<PT,BT> pairComparator

Constructor Detail

AbstractHashTableProber

public AbstractHashTableProber(TypeComparator<PT> probeTypeComparator,
                               TypePairComparator<PT,BT> pairComparator)

Method Detail

getMatchFor

public abstract BT getMatchFor(PT probeSideRecord,
                               BT targetForMatch)

getMatchFor

public abstract BT getMatchFor(PT probeSideRecord)

updateMatch

public abstract void updateMatch(BT record)
                          throws IOException

Throws:

IOException