com.alexkasko.unsafe.offheapstruct

Class OffHeapStructSorterLong.MergeIter

java.lang.Object

com.alexkasko.unsafe.offheapstruct.OffHeapStructSorterLong.MergeIter

All Implemented Interfaces:

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

Enclosing class:

OffHeapStructSorterLong

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

Merge-sort iterator over partly sorted collection

Field Summary

Fields

Modifier and Type	Field and Description
private List<OffHeapStructSorterLong.Worker>	bounds
private byte[]	buf
private OffHeapStructCollection	col
private long[]	indices
private int	keyOffset

Constructor Summary

Constructors

Modifier	Constructor and Description
private	OffHeapStructSorterLong.MergeIter(OffHeapStructCollection col, int keyOffset, List<OffHeapStructSorterLong.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

keyOffset

private final int keyOffset

bounds

private final List<OffHeapStructSorterLong.Worker> bounds

indices

private final long[] indices

buf

private final byte[] buf

Constructor Detail

OffHeapStructSorterLong.MergeIter

private OffHeapStructSorterLong.MergeIter(OffHeapStructCollection col,
                                 int keyOffset,
                                 List<OffHeapStructSorterLong.Worker> bounds)

Private constructor

Parameters:

col - partly sorted collection

keyOffset - key offset 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