Uses of Class
org.apache.flink.runtime.memorymanager.MemoryAllocationException

Packages that use MemoryAllocationException

Package	Description
org.apache.flink.runtime.memorymanager
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

Uses of MemoryAllocationException in org.apache.flink.runtime.memorymanager

Methods in org.apache.flink.runtime.memorymanager that throw MemoryAllocationException

Modifier and Type	Method and Description
List<org.apache.flink.core.memory.MemorySegment>	MemoryManager.allocatePages(AbstractInvokable owner, int numPages)
List<org.apache.flink.core.memory.MemorySegment>	DefaultMemoryManager.allocatePages(AbstractInvokable owner, int numPages)
void	MemoryManager.allocatePages(AbstractInvokable owner, List<org.apache.flink.core.memory.MemorySegment> target, int numPages)
void	DefaultMemoryManager.allocatePages(AbstractInvokable owner, List<org.apache.flink.core.memory.MemorySegment> target, int numPages)

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

Constructors in org.apache.flink.runtime.operators that throw MemoryAllocationException

Constructor and Description
TempBarrier(AbstractInvokable owner, org.apache.flink.util.MutableObjectIterator<T> input, org.apache.flink.api.common.typeutils.TypeSerializerFactory<T> serializerFactory, MemoryManager memManager, IOManager ioManager, int numPages)

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

Methods in org.apache.flink.runtime.operators.hash that throw MemoryAllocationException

Modifier and Type	Method and Description
<BT,PT> MutableHashTable<BT,PT>	ReusingBuildSecondReOpenableHashMatchIterator.getHashJoin(org.apache.flink.api.common.typeutils.TypeSerializer<BT> buildSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<BT> buildSideComparator, org.apache.flink.api.common.typeutils.TypeSerializer<PT> probeSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<PT> probeSideComparator, org.apache.flink.api.common.typeutils.TypePairComparator<PT,BT> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
<BT,PT> MutableHashTable<BT,PT>	NonReusingBuildFirstReOpenableHashMatchIterator.getHashJoin(org.apache.flink.api.common.typeutils.TypeSerializer<BT> buildSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<BT> buildSideComparator, org.apache.flink.api.common.typeutils.TypeSerializer<PT> probeSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<PT> probeSideComparator, org.apache.flink.api.common.typeutils.TypePairComparator<PT,BT> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
<BT,PT> MutableHashTable<BT,PT>	HashMatchIteratorBase.getHashJoin(org.apache.flink.api.common.typeutils.TypeSerializer<BT> buildSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<BT> buildSideComparator, org.apache.flink.api.common.typeutils.TypeSerializer<PT> probeSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<PT> probeSideComparator, org.apache.flink.api.common.typeutils.TypePairComparator<PT,BT> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
<BT,PT> MutableHashTable<BT,PT>	ReusingBuildFirstReOpenableHashMatchIterator.getHashJoin(org.apache.flink.api.common.typeutils.TypeSerializer<BT> buildSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<BT> buildSideComparator, org.apache.flink.api.common.typeutils.TypeSerializer<PT> probeSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<PT> probeSideComparator, org.apache.flink.api.common.typeutils.TypePairComparator<PT,BT> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
<BT,PT> MutableHashTable<BT,PT>	NonReusingBuildSecondReOpenableHashMatchIterator.getHashJoin(org.apache.flink.api.common.typeutils.TypeSerializer<BT> buildSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<BT> buildSideComparator, org.apache.flink.api.common.typeutils.TypeSerializer<PT> probeSideSerializer, org.apache.flink.api.common.typeutils.TypeComparator<PT> probeSideComparator, org.apache.flink.api.common.typeutils.TypePairComparator<PT,BT> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
void	NonReusingBuildSecondHashMatchIterator.open()
void	ReusingBuildSecondHashMatchIterator.open()
void	NonReusingBuildFirstHashMatchIterator.open()
void	ReusingBuildFirstHashMatchIterator.open()

Constructors in org.apache.flink.runtime.operators.hash that throw MemoryAllocationException

Constructor and Description
NonReusingBuildFirstHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
NonReusingBuildFirstReOpenableHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
NonReusingBuildSecondHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
NonReusingBuildSecondReOpenableHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
ReusingBuildFirstHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
ReusingBuildFirstReOpenableHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V2,V1> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
ReusingBuildSecondHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)
ReusingBuildSecondReOpenableHashMatchIterator(org.apache.flink.util.MutableObjectIterator<V1> firstInput, org.apache.flink.util.MutableObjectIterator<V2> secondInput, org.apache.flink.api.common.typeutils.TypeSerializer<V1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<V1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<V2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<V2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<V1,V2> pairComparator, MemoryManager memManager, IOManager ioManager, AbstractInvokable ownerTask, double memoryFraction)

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

Constructors in org.apache.flink.runtime.operators.resettable that throw MemoryAllocationException

Constructor and Description
BlockResettableMutableObjectIterator(MemoryManager memoryManager, org.apache.flink.util.MutableObjectIterator<T> input, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, int numMemoryPages, AbstractInvokable ownerTask)
NonReusingBlockResettableIterator(MemoryManager memoryManager, Iterator<T> input, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, int numPages, AbstractInvokable ownerTask)
NonReusingBlockResettableIterator(MemoryManager memoryManager, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, int numPages, AbstractInvokable ownerTask)
ReusingBlockResettableIterator(MemoryManager memoryManager, Iterator<T> input, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, int numPages, AbstractInvokable ownerTask)
ReusingBlockResettableIterator(MemoryManager memoryManager, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, int numPages, AbstractInvokable ownerTask)
SpillingResettableIterator(Iterator<T> input, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, MemoryManager memoryManager, IOManager ioManager, int numPages, AbstractInvokable parentTask)
SpillingResettableMutableObjectIterator(org.apache.flink.util.MutableObjectIterator<T> input, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, MemoryManager memoryManager, IOManager ioManager, int numPages, AbstractInvokable parentTask)

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

Constructors in org.apache.flink.runtime.operators.sort that throw MemoryAllocationException

Constructor and Description
CombiningUnilateralSortMerger(org.apache.flink.api.common.functions.GroupCombineFunction<E,E> combineStub, MemoryManager memoryManager, IOManager ioManager, org.apache.flink.util.MutableObjectIterator<E> input, AbstractInvokable parentTask, org.apache.flink.api.common.typeutils.TypeSerializerFactory<E> serializerFactory, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, double memoryFraction, int maxNumFileHandles, float startSpillingFraction) Creates a new sorter that reads the data from a given reader and provides an iterator returning that data in a sorted manner.
CombiningUnilateralSortMerger(org.apache.flink.api.common.functions.GroupCombineFunction<E,E> combineStub, MemoryManager memoryManager, IOManager ioManager, org.apache.flink.util.MutableObjectIterator<E> input, AbstractInvokable parentTask, org.apache.flink.api.common.typeutils.TypeSerializerFactory<E> serializerFactory, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, double memoryFraction, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction) Creates a new sorter that reads the data from a given reader and provides an iterator returning that data in a sorted manner.
NonReusingMergeMatchIterator(org.apache.flink.util.MutableObjectIterator<T1> input1, org.apache.flink.util.MutableObjectIterator<T2> input2, org.apache.flink.api.common.typeutils.TypeSerializer<T1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<T1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<T2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<T2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
ReusingMergeMatchIterator(org.apache.flink.util.MutableObjectIterator<T1> input1, org.apache.flink.util.MutableObjectIterator<T2> input2, org.apache.flink.api.common.typeutils.TypeSerializer<T1> serializer1, org.apache.flink.api.common.typeutils.TypeComparator<T1> comparator1, org.apache.flink.api.common.typeutils.TypeSerializer<T2> serializer2, org.apache.flink.api.common.typeutils.TypeComparator<T2> comparator2, org.apache.flink.api.common.typeutils.TypePairComparator<T1,T2> pairComparator, MemoryManager memoryManager, IOManager ioManager, int numMemoryPages, AbstractInvokable parentTask)
UnilateralSortMerger(MemoryManager memoryManager, IOManager ioManager, org.apache.flink.util.MutableObjectIterator<E> input, AbstractInvokable parentTask, org.apache.flink.api.common.typeutils.TypeSerializerFactory<E> serializerFactory, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, double memoryFraction, int maxNumFileHandles, float startSpillingFraction)
UnilateralSortMerger(MemoryManager memoryManager, IOManager ioManager, org.apache.flink.util.MutableObjectIterator<E> input, AbstractInvokable parentTask, org.apache.flink.api.common.typeutils.TypeSerializerFactory<E> serializerFactory, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, double memoryFraction, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction)
UnilateralSortMerger(MemoryManager memoryManager, IOManager ioManager, org.apache.flink.util.MutableObjectIterator<E> input, AbstractInvokable parentTask, org.apache.flink.api.common.typeutils.TypeSerializerFactory<E> serializerFactory, org.apache.flink.api.common.typeutils.TypeComparator<E> comparator, double memoryFraction, int numSortBuffers, int maxNumFileHandles, float startSpillingFraction, boolean noSpillingMemory, boolean handleLargeRecords)

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

Methods in org.apache.flink.runtime.operators.util that throw MemoryAllocationException

Modifier and Type	Method and Description
void	JoinTaskIterator.open() General-purpose open method.
void	CoGroupTaskIterator.open() General-purpose open method.