com.alexkasko.unsafe.offheapstruct

Class OffHeapStructSorterWithComparator.MergeIter

java.lang.Object

com.alexkasko.unsafe.offheapstruct.OffHeapStructSorterWithComparator.MergeIter

All Implemented Interfaces:

OffHeapDisposable, OffHeapDisposableIterator<byte[]>, Iterator<byte[]>

Enclosing class:

OffHeapStructSorterWithComparator

private static class OffHeapStructSorterWithComparator.MergeIter
extends Object
implements OffHeapDisposableIterator<byte[]>

Merge-sort iterator over partly sorted collection

Field Summary

Fields

Modifier and Type	Field and Description
private List<OffHeapStructSorterWithComparator.Worker>	bounds
private byte[]	buf
private OffHeapStructCollection	col
private OffHeapStructComparator	comp
private long[]	indices

Constructor Summary

Constructors

Modifier	Constructor and Description
private	OffHeapStructSorterWithComparator.MergeIter(OffHeapStructCollection col, OffHeapStructComparator comp, List<OffHeapStructSorterWithComparator.Worker> bounds) Private constructor

Method Summary

Methods

Modifier and Type	Method and Description
void	free() Frees allocated memory, may be called multiple times from any thread
boolean	hasNext()
byte[]	next()
void	remove()
long	size() Optional method, should return size of the underlying collections, if such size is known on iterator creation or -1 otherwise

Methods inherited from class java.lang.Object

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

Field Detail

col

private final OffHeapStructCollection col

comp

private final OffHeapStructComparator comp

bounds

private final List<OffHeapStructSorterWithComparator.Worker> bounds

indices

private final long[] indices

buf

private final byte[] buf

Constructor Detail

OffHeapStructSorterWithComparator.MergeIter

private OffHeapStructSorterWithComparator.MergeIter(OffHeapStructCollection col,
                                           OffHeapStructComparator comp,
                                           List<OffHeapStructSorterWithComparator.Worker> bounds)

Private constructor

Parameters:

col - partly sorted collection

comp - comparator used to partially sort collection

bounds - collection sorted parts bounds

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<byte[]>

next

public byte[] next()

Specified by:

next in interface Iterator<byte[]>

remove

public void remove()

Specified by:

remove in interface Iterator<byte[]>

free

public void free()

Frees allocated memory, may be called multiple times from any thread

Specified by:

free in interface OffHeapDisposable

size

public long size()

Optional method, should return size of the underlying collections, if such size is known on iterator creation or -1 otherwise

Specified by:

size in interface OffHeapDisposableIterator<byte[]>

Returns:

number of elements in iterator