Package org.apache.flink.runtime.io.disk
Class SimpleCollectingOutputView
- java.lang.Object
-
- org.apache.flink.runtime.memory.AbstractPagedOutputView
-
- org.apache.flink.runtime.io.disk.SimpleCollectingOutputView
-
- All Implemented Interfaces:
DataOutput
,DataOutputView
,MemorySegmentWritable
public class SimpleCollectingOutputView extends AbstractPagedOutputView
The list with the full segments contains at any point all completely full segments, plus the segment that is currently filled.
-
-
Field Summary
-
Fields inherited from class org.apache.flink.runtime.memory.AbstractPagedOutputView
headerLength, segmentSize
-
-
Constructor Summary
Constructors Constructor Description SimpleCollectingOutputView(List<MemorySegment> fullSegmentTarget, MemorySegmentSource memSource, int segmentSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
getCurrentOffset()
protected MemorySegment
nextSegment(MemorySegment current, int positionInCurrent)
This method must return a segment.void
reset()
-
Methods inherited from class org.apache.flink.runtime.memory.AbstractPagedOutputView
advance, clear, getCurrentPositionInSegment, getCurrentSegment, getHeaderLength, getSegmentSize, seekOutput, skipBytesToWrite, write, write, write, write, write, writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeShort, writeUTF
-
-
-
-
Constructor Detail
-
SimpleCollectingOutputView
public SimpleCollectingOutputView(List<MemorySegment> fullSegmentTarget, MemorySegmentSource memSource, int segmentSize)
-
-
Method Detail
-
reset
public void reset()
-
nextSegment
protected MemorySegment nextSegment(MemorySegment current, int positionInCurrent) throws EOFException
Description copied from class:AbstractPagedOutputView
This method must return a segment. If no more segments are available, it must throw anEOFException
.- Specified by:
nextSegment
in classAbstractPagedOutputView
- Parameters:
current
- The current memory segmentpositionInCurrent
- The position in the segment, one after the last valid byte.- Returns:
- The next memory segment.
- Throws:
EOFException
-
getCurrentOffset
public long getCurrentOffset()
-
-