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 Description ProbeIterator(BinaryRowData instance)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RowData
current()
boolean
hasSource()
BinaryRowData
next()
void
set(ChannelReaderInputViewIterator<BinaryRowData> source)
void
setInstance(RowData instance)
void
setReuse(BinaryRowData reuse)
-
-
-
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()
-
-