org.apache.flink.table.runtime.hashtable

Class LongHashPartition.MatchIterator

java.lang.Object

org.apache.flink.table.runtime.hashtable.LongHashPartition.MatchIterator

All Implemented Interfaces:

RowIterator<BinaryRowData>

Enclosing class:

LongHashPartition

public class LongHashPartition.MatchIterator
extends Object
implements RowIterator<BinaryRowData>

Iterator for probe match.

Constructor Summary

Constructors

Constructor and Description
MatchIterator()

Method Summary

Modifier and Type	Method and Description
boolean	advanceNext() Advance this iterator by a single row.
BinaryRowData	getRow() Retrieve the row from this iterator.
void	set(long address)

Methods inherited from class java.lang.Object

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

Constructor Detail

MatchIterator

public MatchIterator()

Method Detail

set

public void set(long address)

advanceNext

public boolean advanceNext()

Description copied from interface: RowIterator

Advance this iterator by a single row. Returns `false` if this iterator has no more rows and `true` otherwise. If this returns `true`, then the new row can be retrieved by calling RowIterator.getRow().

Specified by:

advanceNext in interface RowIterator<BinaryRowData>

getRow

public BinaryRowData getRow()

Description copied from interface: RowIterator

Retrieve the row from this iterator. This method is idempotent. It is illegal to call this method after [[advanceNext()]] has returned `false`.

Specified by:

getRow in interface RowIterator<BinaryRowData>