org.apache.flink.table.runtime.hashtable

Class ProbeIterator

java.lang.Object

org.apache.flink.table.runtime.hashtable.ProbeIterator

public final class ProbeIterator
extends Object

Probe iterator from probe or spilled partition.

Constructor Summary

Constructors

Constructor and Description
ProbeIterator(BinaryRowData instance)

Method Summary

Modifier and Type	Method and Description
RowData	current()
boolean	hasSource()
BinaryRowData	next()
void	set(ChannelReaderInputViewIterator<BinaryRowData> source)
void	setInstance(RowData instance)
void	setReuse(BinaryRowData reuse)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProbeIterator

public ProbeIterator(BinaryRowData instance)

Method Detail

set

public void set(ChannelReaderInputViewIterator<BinaryRowData> source)

setReuse

public void setReuse(BinaryRowData reuse)

next

public BinaryRowData next()
                   throws IOException

Throws:

IOException

current

public RowData current()

setInstance

public void setInstance(RowData instance)

hasSource

public boolean hasSource()