org.apache.flink.table.runtime.hashtable

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

Modifier and Type	Method and 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

Methods inherited from class java.lang.Object

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

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 an EOFException.

Specified by:

nextSegment in class AbstractPagedOutputView

Parameters:

current - The current memory segment

bytesUsed - The position in the segment, one after the last valid byte.

Returns:

The next memory segment.

Throws:

IOException