Uses of Interface
org.apache.flink.table.runtime.util.RowIterator

Packages that use RowIterator

Package	Description
org.apache.flink.table.runtime.hashtable
org.apache.flink.table.runtime.operators.join
org.apache.flink.table.runtime.operators.window.grouping
org.apache.flink.table.runtime.util

Uses of RowIterator in org.apache.flink.table.runtime.hashtable

Classes in org.apache.flink.table.runtime.hashtable that implement RowIterator

Modifier and Type	Class	Description
class	BuildSideIterator	Iterate all the elements in memory which has not been(or has been) probed during probe phase.
static class	BuildSideIterator.BucketIterator	Partition bucket iterator.
class	LongHashPartition.MatchIterator	Iterator for probe match.
class	LookupBucketIterator	Build iterator from bucket to match probe row.
class	WrappedRowIterator<T extends org.apache.flink.table.data.RowData>	Wrap MutableObjectIterator to java RowIterator.

Methods in org.apache.flink.table.runtime.hashtable that return RowIterator

Modifier and Type	Method	Description
RowIterator<org.apache.flink.table.data.binary.BinaryRowData>	LongHybridHashTable.get(long probeKey)	This method is only used for operator fusion codegen to get build row from hash table.
RowIterator<org.apache.flink.table.data.binary.BinaryRowData>	BinaryHashTable.getBuildSideIterator()
RowIterator	BinaryHashTable.getSpilledPartitionBuildSideIter(BinaryHashPartition p)
RowIterator	LongHybridHashTable.getSpilledPartitionBuildSideIter(LongHashPartition p)

Uses of RowIterator in org.apache.flink.table.runtime.operators.join

Methods in org.apache.flink.table.runtime.operators.join with parameters of type RowIterator

Modifier and Type	Method	Description
abstract void	HashJoinOperator.join(RowIterator<org.apache.flink.table.data.binary.BinaryRowData> buildIter, org.apache.flink.table.data.RowData probeRow)

Uses of RowIterator in org.apache.flink.table.runtime.operators.window.grouping

Methods in org.apache.flink.table.runtime.operators.window.grouping that return RowIterator

Modifier and Type	Method	Description
RowIterator<org.apache.flink.table.data.binary.BinaryRowData>	WindowsGrouping.buildTriggerWindowElementsIterator()
protected RowIterator<org.apache.flink.table.data.binary.BinaryRowData>	HeapWindowsGrouping.newBufferIterator(int startIndex)
protected abstract RowIterator<org.apache.flink.table.data.binary.BinaryRowData>	WindowsGrouping.newBufferIterator(int startIndex)

Uses of RowIterator in org.apache.flink.table.runtime.util

Subinterfaces of RowIterator in org.apache.flink.table.runtime.util

Modifier and Type	Interface	Description
static interface	ResettableRowBuffer.ResettableIterator	Row iterator that can be reset.

Classes in org.apache.flink.table.runtime.util that implement RowIterator

Modifier and Type	Class	Description
class	ResettableExternalBuffer.BufferIterator	Iterator of external buffer.