org.apache.flink.runtime.memory

Class ListMemorySegmentSource

java.lang.Object

org.apache.flink.runtime.memory.ListMemorySegmentSource

All Implemented Interfaces:

MemorySegmentSource

public class ListMemorySegmentSource
extends Object
implements MemorySegmentSource

Simple memory segment source that draws segments from a list.

Constructor Summary

Constructors

Constructor and Description
ListMemorySegmentSource(List<MemorySegment> memorySegments)

Method Summary

Modifier and Type	Method and Description
MemorySegment	nextSegment() Gets the next memory segment.

Methods inherited from class java.lang.Object

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

Constructor Detail

ListMemorySegmentSource

public ListMemorySegmentSource(List<MemorySegment> memorySegments)

Method Detail

nextSegment

public MemorySegment nextSegment()

Description copied from interface: MemorySegmentSource

Gets the next memory segment. If no more segments are available, it returns null.

Specified by:

nextSegment in interface MemorySegmentSource

Returns:

The next memory segment, or null, if none is available.