org.apache.ignite.internal.processors.hadoop.shuffle.collections

Class HadoopSkipList

java.lang.Object

org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase

org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopSkipList

All Implemented Interfaces:

AutoCloseable, HadoopMultimap

public class HadoopSkipList
extends HadoopMultimapBase

Skip list.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase

HadoopMultimapBase.AdderBase, HadoopMultimapBase.ReaderBase, HadoopMultimapBase.ValueIterator

Nested classes/interfaces inherited from interface org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimap

HadoopMultimap.Adder, HadoopMultimap.Key, HadoopMultimap.Value, HadoopMultimap.Visitor

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase

mem, pageSize

Constructor Summary

Constructors

Constructor and Description
HadoopSkipList(HadoopJobInfo jobInfo, GridUnsafeMemory mem)

Method Summary

Modifier and Type	Method and Description
void	close()
HadoopTaskInput	input(HadoopTaskContext taskCtx)
static int	randomLevel(Random rnd)
HadoopMultimap.Adder	startAdding(HadoopTaskContext ctx)
boolean	visit(boolean ignoreLastVisited, HadoopMultimap.Visitor v) Incrementally visits all the keys and values in the map.

Methods inherited from class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase

nextValue, nextValue, valueSize, valueSize

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopSkipList

public HadoopSkipList(HadoopJobInfo jobInfo,
                      GridUnsafeMemory mem)

Parameters:

jobInfo - Job info.

mem - Memory.

Method Detail

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface HadoopMultimap

Overrides:

close in class HadoopMultimapBase

visit

public boolean visit(boolean ignoreLastVisited,
                     HadoopMultimap.Visitor v)
              throws IgniteCheckedException

Incrementally visits all the keys and values in the map.

Parameters:

ignoreLastVisited - Flag indicating that visiting must be started from the beginning.

v - Visitor.

Returns:

false If visiting was impossible.

Throws:

IgniteCheckedException

startAdding

public HadoopMultimap.Adder startAdding(HadoopTaskContext ctx)
                                 throws IgniteCheckedException

Parameters:

ctx - Task context.

Returns:

Adder.

Throws:

IgniteCheckedException - If failed.

input

public HadoopTaskInput input(HadoopTaskContext taskCtx)
                      throws IgniteCheckedException

Parameters:

taskCtx - Task context.

Returns:

Task input.

Throws:

IgniteCheckedException - If failed.

randomLevel

public static int randomLevel(Random rnd)

Parameters:

rnd - Random.

Returns:

Next level.