public class SpillingBuffer extends AbstractPagedOutputView
headerLength, segmentSize
Constructor and Description |
---|
SpillingBuffer(IOManager ioManager,
MemorySegmentSource memSource,
int segmentSize) |
Modifier and Type | Method and Description |
---|---|
List<MemorySegment> |
close() |
DataInputView |
flip() |
protected MemorySegment |
nextSegment(MemorySegment current,
int positionInCurrent)
This method must return a segment.
|
advance, clear, getCurrentPositionInSegment, getCurrentSegment, getHeaderLength, getSegmentSize, seekOutput, skipBytesToWrite, write, write, write, write, write, writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeShort, writeUTF
public SpillingBuffer(IOManager ioManager, MemorySegmentSource memSource, int segmentSize)
protected MemorySegment nextSegment(MemorySegment current, int positionInCurrent) throws IOException
AbstractPagedOutputView
EOFException
.nextSegment
in class AbstractPagedOutputView
current
- The current memory segmentpositionInCurrent
- The position in the segment, one after the last valid byte.IOException
public DataInputView flip() throws IOException
IOException
public List<MemorySegment> close() throws IOException
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.