Class BytesHashMapSpillMemorySegmentPool

    • Constructor Detail

      • BytesHashMapSpillMemorySegmentPool

        public BytesHashMapSpillMemorySegmentPool​(List<org.apache.flink.core.memory.MemorySegment> memorySegments)
    • Method Detail

      • nextSegment

        public org.apache.flink.core.memory.MemorySegment nextSegment()
        Specified by:
        nextSegment in interface org.apache.flink.core.memory.MemorySegmentSource
      • returnAll

        public void returnAll​(List<org.apache.flink.core.memory.MemorySegment> memory)
        Description copied from interface: MemorySegmentPool
        Return all pages back into this pool.
        Specified by:
        returnAll in interface MemorySegmentPool
        Parameters:
        memory - the pages which want to be returned.
      • pageSize

        public int pageSize()
        Description copied from interface: MemorySegmentPool
        Get the page size of each page this pool holds.
        Specified by:
        pageSize in interface MemorySegmentPool
        Returns:
        the page size