Uses of Interface
org.apache.flink.util.MutableObjectIterator

Packages that use MutableObjectIterator

Package	Description
org.apache.flink.runtime.io.disk
org.apache.flink.runtime.iterative.io
org.apache.flink.runtime.operators
org.apache.flink.runtime.operators.hash
org.apache.flink.runtime.operators.resettable
org.apache.flink.runtime.operators.sort
org.apache.flink.runtime.operators.util
org.apache.flink.runtime.operators.util.metrics
org.apache.flink.runtime.util
org.apache.flink.table.runtime.hashtable
org.apache.flink.table.runtime.io
org.apache.flink.table.runtime.operators.aggregate
org.apache.flink.table.runtime.operators.join
org.apache.flink.table.runtime.operators.sort

Uses of MutableObjectIterator in org.apache.flink.runtime.io.disk

Classes in org.apache.flink.runtime.io.disk that implement MutableObjectIterator

Modifier and Type	Class and Description
class	ChannelReaderInputViewIterator<E> A simple iterator over the input read though an I/O channel.
class	InputViewIterator<E>

Uses of MutableObjectIterator in org.apache.flink.runtime.iterative.io

Classes in org.apache.flink.runtime.iterative.io that implement MutableObjectIterator

Modifier and Type	Class and Description
class	HashPartitionIterator<BT,PT> Iterator over the build side entries of a HashPartition.

Uses of MutableObjectIterator in org.apache.flink.runtime.operators

Fields in org.apache.flink.runtime.operators declared as MutableObjectIterator

Modifier and Type	Field and Description
protected MutableObjectIterator<?>[]	BatchTask.inputIterators The inputs reader, wrapped in an iterator.
protected MutableObjectIterator<?>[]	BatchTask.inputs The inputs to the operator.

Methods in org.apache.flink.runtime.operators that return MutableObjectIterator

Modifier and Type	Method and Description
protected MutableObjectIterator<?>	BatchTask.createInputIterator(MutableReader<?> inputReader, TypeSerializerFactory<?> serializerFactory)
<X> MutableObjectIterator<X>	BatchTask.getInput(int index)
<X> MutableObjectIterator<X>	TaskContext.getInput(int index)
MutableObjectIterator<T>	TempBarrier.getIterator() This method resets the input!

Methods in org.apache.flink.runtime.operators with parameters of type MutableObjectIterator

Modifier and Type	Method and Description
protected JoinTaskIterator<IT1,IT2,OT>	FullOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	FullOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	LeftOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	LeftOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected abstract JoinTaskIterator<IT1,IT2,OT>	AbstractOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected abstract JoinTaskIterator<IT1,IT2,OT>	AbstractOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	RightOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	RightOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	FullOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	FullOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	LeftOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	LeftOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected abstract JoinTaskIterator<IT1,IT2,OT>	AbstractOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected abstract JoinTaskIterator<IT1,IT2,OT>	AbstractOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	RightOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	RightOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)

Constructors in org.apache.flink.runtime.operators with parameters of type MutableObjectIterator

Constructor and Description
SimpleIterable(IN reuse, MutableObjectIterator<IN> iterator)
SimpleIterator(IN reuse, MutableObjectIterator<IN> iterator)
TempBarrier(AbstractInvokable owner, MutableObjectIterator<T> input, TypeSerializerFactory<T> serializerFactory, MemoryManager memManager, IOManager ioManager, int numPages)

Uses of MutableObjectIterator in org.apache.flink.runtime.operators.hash

Classes in org.apache.flink.runtime.operators.hash that implement MutableObjectIterator

Modifier and Type	Class and Description
class	CompactingHashTable.EntryIterator Iterator that traverses the whole hash table once If entries are inserted during iteration they may be overlooked by the iterator
class	InPlaceMutableHashTable.EntryIterator WARNING: Doing any other operation on the table invalidates the iterator! (Even using getMatchFor of a prober!)
static class	MutableHashTable.HashBucketIterator<BT,PT>
static class	MutableHashTable.UnmatchedBuildIterator<BT,PT> Iterate all the elements in memory which has not been probed during probe phase.

Methods in org.apache.flink.runtime.operators.hash that return MutableObjectIterator

Modifier and Type	Method and Description
MutableObjectIterator<BT>	MutableHashTable.getBuildSideIterator()
MutableObjectIterator<T>	CompactingHashTable.getEntryIterator()
abstract MutableObjectIterator<T>	AbstractMutableHashTable.getEntryIterator()

Methods in org.apache.flink.runtime.operators.hash with parameters of type MutableObjectIterator

Modifier and Type	Method and Description
protected void	MutableHashTable.buildInitialTable(MutableObjectIterator<BT> input) Creates the initial hash table.
void	CompactingHashTable.buildTableWithUniqueKey(MutableObjectIterator<T> input)
void	MutableHashTable.open(MutableObjectIterator<BT> buildSide, MutableObjectIterator<PT> probeSide) Opens the hash join.
void	MutableHashTable.open(MutableObjectIterator<BT> buildSide, MutableObjectIterator<PT> probeSide) Opens the hash join.
void	ReOpenableMutableHashTable.open(MutableObjectIterator<BT> buildSide, MutableObjectIterator<PT> probeSide, boolean buildSideOuterJoin)
void	ReOpenableMutableHashTable.open(MutableObjectIterator<BT> buildSide, MutableObjectIterator<PT> probeSide, boolean buildSideOuterJoin)
void	MutableHashTable.open(MutableObjectIterator<BT> buildSide, MutableObjectIterator<PT> probeSide, boolean buildOuterJoin) Opens the hash join.
void	MutableHashTable.open(MutableObjectIterator<BT> buildSide, MutableObjectIterator<PT> probeSide, boolean buildOuterJoin) Opens the hash join.
void	ReOpenableMutableHashTable.reopenProbe(MutableObjectIterator<PT> probeInput)
void	NonReusingBuildSecondReOpenableHashJoinIterator.reopenProbe(MutableObjectIterator<V1> probeInput) Set new input for probe side
void	ReusingBuildSecondReOpenableHashJoinIterator.reopenProbe(MutableObjectIterator<V1> probeInput) Set new input for probe side
void	NonReusingBuildFirstReOpenableHashJoinIterator.reopenProbe(MutableObjectIterator<V2> probeInput) Set new input for probe side
void	ReusingBuildFirstReOpenableHashJoinIterator.reopenProbe(MutableObjectIterator<V2> probeInput) Set new input for probe side

Constructors in org.apache.flink.runtime.operators.hash with parameters of type MutableObjectIterator

Constructor and Description
NonReusingBuildFirstHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
NonReusingBuildFirstHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
NonReusingBuildFirstReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
NonReusingBuildFirstReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
NonReusingBuildSecondHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
NonReusingBuildSecondHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
NonReusingBuildSecondReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
NonReusingBuildSecondReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
ReusingBuildFirstHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
ReusingBuildFirstHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
ReusingBuildFirstReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
ReusingBuildFirstReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
ReusingBuildSecondHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
ReusingBuildSecondHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
ReusingBuildSecondReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)
ReusingBuildSecondReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput, MutableObjectIterator<V2> secondInput, TypeSerializer<V1> serializer1, TypeComparator<V1> comparator1, TypeSerializer<V2> serializer2, TypeComparator<V2> comparator2, TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction, boolean probeSideOuterJoin, boolean buildSideOuterJoin, boolean useBitmapFilters)

Uses of MutableObjectIterator in org.apache.flink.runtime.operators.resettable

Classes in org.apache.flink.runtime.operators.resettable that implement MutableObjectIterator

Modifier and Type	Class and Description
class	BlockResettableMutableObjectIterator<T> Implementation of an iterator that fetches a block of data into main memory and offers resettable access to the data in that block.
class	SpillingResettableMutableObjectIterator<T> Implementation of a resettable iterator.

Fields in org.apache.flink.runtime.operators.resettable declared as MutableObjectIterator

Modifier and Type	Field and Description
protected MutableObjectIterator<T>	SpillingResettableMutableObjectIterator.input

Constructors in org.apache.flink.runtime.operators.resettable with parameters of type MutableObjectIterator

Constructor and Description
BlockResettableMutableObjectIterator(MemoryManager memoryManager, MutableObjectIterator<T> input, TypeSerializer<T> serializer, int numMemoryPages, AbstractInvokable ownerTask)
SpillingResettableMutableObjectIterator(MutableObjectIterator<T> input, TypeSerializer<T> serializer, MemoryManager memoryManager, IOManager ioManager, int numPages, AbstractInvokable parentTask)
SpillingResettableMutableObjectIterator(MutableObjectIterator<T> input, TypeSerializer<T> serializer, MemoryManager memoryManager, IOManager ioManager, List<MemorySegment> memory)

Uses of MutableObjectIterator in org.apache.flink.runtime.operators.sort

Classes in org.apache.flink.runtime.operators.sort that implement MutableObjectIterator

Modifier and Type	Class and Description
class	MergeIterator<E> An iterator that returns a sorted merge of the sequences of elements from a set of iterators, assuming those sequences are ordered themselves.

Fields in org.apache.flink.runtime.operators.sort declared as MutableObjectIterator

Modifier and Type	Field and Description
protected MutableObjectIterator<E>	UnilateralSortMerger.iterator The iterator to be returned by the sort-merger.

Methods in org.apache.flink.runtime.operators.sort that return MutableObjectIterator

Modifier and Type	Method and Description
MutableObjectIterator<T>	LargeRecordHandler.finishWriteAndSortKeys(List<MemorySegment> memory)
MutableObjectIterator<E>	UnilateralSortMerger.getIterator()
MutableObjectIterator<E>	Sorter.getIterator()
MutableObjectIterator<T>	InMemorySorter.getIterator() Gets an iterator over all records in this buffer in their logical order.
MutableObjectIterator<T>	FixedLengthRecordSorter.getIterator() Gets an iterator over all records in this buffer in their logical order.
MutableObjectIterator<T>	NormalizedKeySorter.getIterator() Gets an iterator over all records in this buffer in their logical order.

Methods in org.apache.flink.runtime.operators.sort with parameters of type MutableObjectIterator

Modifier and Type	Method and Description
protected <T> KeyGroupedIterator<T>	NonReusingMergeInnerJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input, TypeSerializer<T> serializer, TypeComparator<T> comparator)
protected abstract <T> KeyGroupedIterator<T>	AbstractMergeIterator.createKeyGroupedIterator(MutableObjectIterator<T> input, TypeSerializer<T> serializer, TypeComparator<T> comparator)
protected <T> KeyGroupedIterator<T>	NonReusingMergeOuterJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input, TypeSerializer<T> serializer, TypeComparator<T> comparator)
protected <T> KeyGroupedIterator<T>	ReusingMergeInnerJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input, TypeSerializer<T> serializer, TypeComparator<T> comparator)
protected <T> KeyGroupedIterator<T>	ReusingMergeOuterJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input, TypeSerializer<T> serializer, TypeComparator<T> comparator)
protected MergeIterator<E>	UnilateralSortMerger.SpillingThread.getMergingIterator(List<UnilateralSortMerger.ChannelWithBlockCount> channelIDs, List<List<MemorySegment>> inputSegments, List<FileIOChannel> readerList, MutableObjectIterator<E> largeRecords) Returns an iterator that iterates over the merged result from all given channels.
protected UnilateralSortMerger.ThreadBase<E>	UnilateralSortMerger.getReadingThread(ExceptionHandler<IOException> exceptionHandler, MutableObjectIterator<E> reader, UnilateralSortMerger.CircularQueues<E> queues, LargeRecordHandler<E> largeRecordHandler, AbstractInvokable parentTask, TypeSerializer<E> serializer, long startSpillingBytes) Creates the reading thread.
protected void	UnilateralSortMerger.setResultIterator(MutableObjectIterator<E> iterator) Sets the result iterator.

Constructors in org.apache.flink.runtime.operators.sort with parameters of type MutableObjectIterator

Constructor and Description
AbstractMergeInnerJoinIterator(MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
AbstractMergeInnerJoinIterator(MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
AbstractMergeIterator(MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
AbstractMergeIterator(MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
AbstractMergeOuterJoinIterator(OuterJoinOperatorBase.OuterJoinType outerJoinType, MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
AbstractMergeOuterJoinIterator(OuterJoinOperatorBase.OuterJoinType outerJoinType, MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
CombiningUnilateralSortMerger(GroupCombineFunction<E,E> combineStub, MemoryManager memoryManager, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, double memoryFraction, int maxNumFileHandles, float startSpillingFraction, boolean handleLargeRecords, boolean objectReuseEnabled) Creates a new sorter that reads the data from a given reader and provides an iterator returning that data in a sorted manner.
CombiningUnilateralSortMerger(GroupCombineFunction<E,E> combineStub, MemoryManager memoryManager, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, double memoryFraction, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean handleLargeRecords, boolean objectReuseEnabled) Creates a new sorter that reads the data from a given reader and provides an iterator returning that data in a sorted manner.
NonReusingMergeInnerJoinIterator(MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
NonReusingMergeInnerJoinIterator(MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
NonReusingMergeOuterJoinIterator(OuterJoinOperatorBase.OuterJoinType outerJoinType, MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
NonReusingMergeOuterJoinIterator(OuterJoinOperatorBase.OuterJoinType outerJoinType, MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
NonReusingSortMergeCoGroupIterator(MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> groupingComparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> groupingComparator2, TypePairComparator<T1,T2> pairComparator)
NonReusingSortMergeCoGroupIterator(MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> groupingComparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> groupingComparator2, TypePairComparator<T1,T2> pairComparator)
ReadingThread(ExceptionHandler<IOException> exceptionHandler, MutableObjectIterator<E> reader, UnilateralSortMerger.CircularQueues<E> queues, LargeRecordHandler<E> largeRecordsHandler, E readTarget, AbstractInvokable parentTask, long startSpillingBytes) Creates a new reading thread.
ReusingMergeInnerJoinIterator(MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
ReusingMergeInnerJoinIterator(MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
ReusingMergeOuterJoinIterator(OuterJoinOperatorBase.OuterJoinType outerJoinType, MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
ReusingMergeOuterJoinIterator(OuterJoinOperatorBase.OuterJoinType outerJoinType, MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> comparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> comparator2, TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
ReusingSortMergeCoGroupIterator(MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> groupingComparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> groupingComparator2, TypePairComparator<T1,T2> pairComparator)
ReusingSortMergeCoGroupIterator(MutableObjectIterator<T1> input1, MutableObjectIterator<T2> input2, TypeSerializer<T1> serializer1, TypeComparator<T1> groupingComparator1, TypeSerializer<T2> serializer2, TypeComparator<T2> groupingComparator2, TypePairComparator<T1,T2> pairComparator)
UnilateralSortMerger(MemoryManager memoryManager, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, double memoryFraction, int maxNumFileHandles, float startSpillingFraction, boolean handleLargeRecords, boolean objectReuseEnabled)
UnilateralSortMerger(MemoryManager memoryManager, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, double memoryFraction, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean handleLargeRecords, boolean objectReuseEnabled)
UnilateralSortMerger(MemoryManager memoryManager, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, double memoryFraction, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean noSpillingMemory, boolean handleLargeRecords, boolean objectReuseEnabled)
UnilateralSortMerger(MemoryManager memoryManager, List<MemorySegment> memory, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean handleLargeRecords, boolean objectReuseEnabled)
UnilateralSortMerger(MemoryManager memoryManager, List<MemorySegment> memory, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean noSpillingMemory, boolean handleLargeRecords, boolean objectReuseEnabled)
UnilateralSortMerger(MemoryManager memoryManager, List<MemorySegment> memory, IOManager ioManager, MutableObjectIterator<E> input, AbstractInvokable parentTask, TypeSerializerFactory<E> serializerFactory, TypeComparator<E> comparator, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean noSpillingMemory, boolean handleLargeRecords, boolean objectReuseEnabled, InMemorySorterFactory<E> inMemorySorterFactory)

Constructor parameters in org.apache.flink.runtime.operators.sort with type arguments of type MutableObjectIterator

Constructor and Description
MergeIterator(List<MutableObjectIterator<E>> iterators, TypeComparator<E> comparator)

Uses of MutableObjectIterator in org.apache.flink.runtime.operators.util

Classes in org.apache.flink.runtime.operators.util that implement MutableObjectIterator

Modifier and Type	Class and Description
class	ReaderIterator<T> A MutableObjectIterator that wraps a reader from an input channel and produces the reader's records.

Methods in org.apache.flink.runtime.operators.util that return MutableObjectIterator

Modifier and Type	Method and Description
MutableObjectIterator<E>	SimpleCloseableInputProvider.getIterator()
MutableObjectIterator<E>	CloseableInputProvider.getIterator() Gets the iterator over this input.

Constructors in org.apache.flink.runtime.operators.util with parameters of type MutableObjectIterator

Constructor and Description
SimpleCloseableInputProvider(MutableObjectIterator<E> iterator) Creates a new simple input provider that will return the given iterator.

Uses of MutableObjectIterator in org.apache.flink.runtime.operators.util.metrics

Classes in org.apache.flink.runtime.operators.util.metrics that implement MutableObjectIterator

Modifier and Type	Class and Description
class	CountingMutableObjectIterator<IN>

Constructors in org.apache.flink.runtime.operators.util.metrics with parameters of type MutableObjectIterator

Constructor and Description
CountingMutableObjectIterator(MutableObjectIterator<IN> iterator, Counter numRecordsIn)

Uses of MutableObjectIterator in org.apache.flink.runtime.util

Subinterfaces of MutableObjectIterator in org.apache.flink.runtime.util

Modifier and Type	Interface and Description
interface	ResettableMutableObjectIterator<E> The resettable iterator is a specialization of the iterator, allowing to reset the iterator and re-retrieve elements.

Classes in org.apache.flink.runtime.util that implement MutableObjectIterator

Modifier and Type	Class and Description
class	EmptyMutableObjectIterator<E> An empty mutable object iterator that never returns anything.
class	RegularToMutableObjectIterator<T>

Methods in org.apache.flink.runtime.util that return MutableObjectIterator

Modifier and Type	Method and Description
static <E> MutableObjectIterator<E>	EmptyMutableObjectIterator.get() Gets a singleton instance of the empty iterator.

Constructors in org.apache.flink.runtime.util with parameters of type MutableObjectIterator

Constructor and Description
NonReusingKeyGroupedIterator(MutableObjectIterator<E> iterator, TypeComparator<E> comparator) Initializes the KeyGroupedIterator.
NonReusingMutableToRegularIteratorWrapper(MutableObjectIterator<T> source, TypeSerializer<T> serializer)
ReusingKeyGroupedIterator(MutableObjectIterator<E> iterator, TypeSerializer<E> serializer, TypeComparator<E> comparator) Initializes the KeyGroupedIterator.
ReusingMutableToRegularIteratorWrapper(MutableObjectIterator<T> source, TypeSerializer<T> serializer)

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

Constructors in org.apache.flink.table.runtime.hashtable with parameters of type MutableObjectIterator

Constructor and Description
WrappedRowIterator(MutableObjectIterator<T> iterator, T reuse)

Uses of MutableObjectIterator in org.apache.flink.table.runtime.io

Classes in org.apache.flink.table.runtime.io that implement MutableObjectIterator

Modifier and Type	Class and Description
class	BinaryRowChannelInputViewIterator A simple iterator over the input read though an I/O channel.

Uses of MutableObjectIterator in org.apache.flink.table.runtime.operators.aggregate

Methods in org.apache.flink.table.runtime.operators.aggregate that return MutableObjectIterator

Modifier and Type	Method and Description
MutableObjectIterator<BytesHashMap.Entry>	BytesHashMap.getEntryIterator() Returns a destructive iterator for iterating over the entries of this map.

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

Constructors in org.apache.flink.table.runtime.operators.join with parameters of type MutableObjectIterator

Constructor and Description
SortMergeFullOuterJoinIterator(BinaryRowSerializer serializer1, BinaryRowSerializer serializer2, Projection<BaseRow,BinaryRow> projection1, Projection<BaseRow,BinaryRow> projection2, RecordComparator keyComparator, MutableObjectIterator<BinaryRow> iterator1, MutableObjectIterator<BinaryRow> iterator2, ResettableExternalBuffer buffer1, ResettableExternalBuffer buffer2, boolean[] filterNulls)
SortMergeFullOuterJoinIterator(BinaryRowSerializer serializer1, BinaryRowSerializer serializer2, Projection<BaseRow,BinaryRow> projection1, Projection<BaseRow,BinaryRow> projection2, RecordComparator keyComparator, MutableObjectIterator<BinaryRow> iterator1, MutableObjectIterator<BinaryRow> iterator2, ResettableExternalBuffer buffer1, ResettableExternalBuffer buffer2, boolean[] filterNulls)
SortMergeInnerJoinIterator(BinaryRowSerializer probeSerializer, BinaryRowSerializer bufferedSerializer, Projection probeProjection, Projection bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<BaseRow> probeIterator, MutableObjectIterator<BinaryRow> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys)
SortMergeInnerJoinIterator(BinaryRowSerializer probeSerializer, BinaryRowSerializer bufferedSerializer, Projection probeProjection, Projection bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<BaseRow> probeIterator, MutableObjectIterator<BinaryRow> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys)
SortMergeJoinIterator(BinaryRowSerializer probeSerializer, BinaryRowSerializer bufferedSerializer, Projection<BaseRow,BinaryRow> probeProjection, Projection<BaseRow,BinaryRow> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<BaseRow> probeIterator, MutableObjectIterator<BinaryRow> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNulls)
SortMergeJoinIterator(BinaryRowSerializer probeSerializer, BinaryRowSerializer bufferedSerializer, Projection<BaseRow,BinaryRow> probeProjection, Projection<BaseRow,BinaryRow> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<BaseRow> probeIterator, MutableObjectIterator<BinaryRow> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNulls)
SortMergeOneSideOuterJoinIterator(BinaryRowSerializer probeSerializer, BinaryRowSerializer bufferedSerializer, Projection<BaseRow,BinaryRow> probeProjection, Projection<BaseRow,BinaryRow> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<BaseRow> probeIterator, MutableObjectIterator<BinaryRow> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys)
SortMergeOneSideOuterJoinIterator(BinaryRowSerializer probeSerializer, BinaryRowSerializer bufferedSerializer, Projection<BaseRow,BinaryRow> probeProjection, Projection<BaseRow,BinaryRow> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<BaseRow> probeIterator, MutableObjectIterator<BinaryRow> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys)

Uses of MutableObjectIterator in org.apache.flink.table.runtime.operators.sort

Classes in org.apache.flink.table.runtime.operators.sort that implement MutableObjectIterator

Modifier and Type	Class and Description
class	BinaryMergeIterator<Entry> Binary version of MergeIterator.
class	ChannelReaderKVInputViewIterator<K,V> Key-Value style channel reader input view iterator.

Methods in org.apache.flink.table.runtime.operators.sort that return MutableObjectIterator

Modifier and Type	Method and Description
protected MutableObjectIterator<BinaryRow>	BinaryExternalMerger.channelReaderInputViewIterator(AbstractChannelReaderInputView inView)
protected MutableObjectIterator<Tuple2<BinaryRow,BinaryRow>>	BinaryKVExternalMerger.channelReaderInputViewIterator(AbstractChannelReaderInputView inView)
protected abstract MutableObjectIterator<Entry>	AbstractBinaryExternalMerger.channelReaderInputViewIterator(AbstractChannelReaderInputView inView)
MutableObjectIterator<BinaryRow>	BinaryExternalSorter.getIterator()
MutableObjectIterator<Tuple2<BinaryRow,BinaryRow>>	BinaryKVInMemorySortBuffer.getIterator() Gets an iterator over all KV records in this buffer in their logical order.
MutableObjectIterator<BinaryRow>	BinaryInMemorySortBuffer.getIterator() Gets an iterator over all records in this buffer in their logical order.
MutableObjectIterator<Tuple2<BinaryRow,BinaryRow>>	BufferedKVExternalSorter.getKVIterator()

Methods in org.apache.flink.table.runtime.operators.sort with parameters of type MutableObjectIterator

Modifier and Type	Method and Description
void	BinaryExternalSorter.write(MutableObjectIterator<BinaryRow> iterator)
protected void	BinaryExternalMerger.writeMergingOutput(MutableObjectIterator<BinaryRow> mergeIterator, AbstractPagedOutputView output)
protected abstract void	AbstractBinaryExternalMerger.writeMergingOutput(MutableObjectIterator<Entry> mergeIterator, AbstractPagedOutputView output) read the merged stream and write the data back.
protected void	BinaryKVExternalMerger.writeMergingOutput(MutableObjectIterator<Tuple2<BinaryRow,BinaryRow>> mergeIterator, AbstractPagedOutputView output)

Constructor parameters in org.apache.flink.table.runtime.operators.sort with type arguments of type MutableObjectIterator

Constructor and Description
BinaryMergeIterator(List<MutableObjectIterator<Entry>> iterators, List<Entry> reusableEntries, Comparator<Entry> comparator)