Class BinaryHashPartition.BuildSideBuffer
- java.lang.Object
-
- org.apache.flink.runtime.memory.AbstractPagedOutputView
-
- org.apache.flink.table.runtime.hashtable.BinaryHashPartition.BuildSideBuffer
-
- All Implemented Interfaces:
DataOutput
,DataOutputView
,MemorySegmentWritable
- Enclosing class:
- BinaryHashPartition
protected static final class BinaryHashPartition.BuildSideBuffer extends AbstractPagedOutputView
Build side buffer.
-
-
Field Summary
-
Fields inherited from class org.apache.flink.runtime.memory.AbstractPagedOutputView
headerLength, segmentSize
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected MemorySegment
nextSegment(MemorySegment current, int bytesUsed)
This method must return a segment.-
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
-
-
-
-
Method Detail
-
nextSegment
protected MemorySegment nextSegment(MemorySegment current, int bytesUsed) throws IOException
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 segmentbytesUsed
- The position in the segment, one after the last valid byte.- Returns:
- The next memory segment.
- Throws:
IOException
-
-