Class LookupBucketIterator
- java.lang.Object
-
- org.apache.flink.table.runtime.hashtable.LookupBucketIterator
-
- All Implemented Interfaces:
RowIterator<BinaryRowData>
public class LookupBucketIterator extends Object implements RowIterator<BinaryRowData>
Build iterator from bucket to match probe row.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
advanceNext()
Advance this iterator by a single row.BinaryRowData
getRow()
Retrieve the row from this iterator.void
set(MemorySegment bucket, MemorySegment[] overflowSegments, BinaryHashPartition partition, int searchHashCode, int bucketInSegmentOffset)
-
-
-
Method Detail
-
set
public void set(MemorySegment bucket, MemorySegment[] overflowSegments, BinaryHashPartition partition, int searchHashCode, int bucketInSegmentOffset)
-
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 callingRowIterator.getRow()
.- Specified by:
advanceNext
in interfaceRowIterator<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 interfaceRowIterator<BinaryRowData>
-
-