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

Class HadoopMultimapBase

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, HadoopMultimap

Direct Known Subclasses:

HadoopHashMultimapBase, HadoopSkipList

public abstract class HadoopMultimapBase
extends Object
implements HadoopMultimap

Base class for all multimaps.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	HadoopMultimapBase.AdderBase Base class for adders.
protected class	HadoopMultimapBase.ReaderBase Reader for key and value.
protected class	HadoopMultimapBase.ValueIterator Iterator over values.

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

Modifier and Type	Field and Description
protected GridUnsafeMemory	mem
protected int	pageSize

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HadoopMultimapBase(HadoopJobInfo jobInfo, GridUnsafeMemory mem)

Method Summary

Modifier and Type	Method and Description
void	close()
protected long	nextValue(long valPtr)
protected void	nextValue(long valPtr, long nextValPtr)
protected int	valueSize(long valPtr)
protected void	valueSize(long valPtr, int size)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimap

input, startAdding, visit

Field Detail

mem

protected final GridUnsafeMemory mem

pageSize

protected final int pageSize

Constructor Detail

HadoopMultimapBase

protected HadoopMultimapBase(HadoopJobInfo jobInfo,
                             GridUnsafeMemory mem)

Parameters:

jobInfo - Job info.

mem - Memory.

Method Detail

nextValue

protected void nextValue(long valPtr,
                         long nextValPtr)

Parameters:

valPtr - Value page pointer.

nextValPtr - Next value page pointer.

nextValue

protected long nextValue(long valPtr)

Parameters:

valPtr - Value page pointer.

Returns:

Next value page pointer.

valueSize

protected void valueSize(long valPtr,
                         int size)

Parameters:

valPtr - Value page pointer.

size - Size.

valueSize

protected int valueSize(long valPtr)

Parameters:

valPtr - Value page pointer.

Returns:

Value size.

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface HadoopMultimap