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

Class HadoopHashMultimap

java.lang.Object

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

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

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

All Implemented Interfaces:

AutoCloseable, HadoopMultimap

public class HadoopHashMultimap
extends HadoopHashMultimapBase

Hash multimap.

Nested Class Summary

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

HadoopHashMultimapBase.Input, HadoopHashMultimapBase.Reader

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
HadoopHashMultimap(HadoopJobInfo jobInfo, GridUnsafeMemory mem, int cap)

Method Summary

Modifier and Type	Method and Description
int	capacity()
int	keys()
protected long	meta(int idx)
HadoopMultimap.Adder	startAdding(HadoopTaskContext ctx)

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

collision, collision, input, key, keyHash, keySize, value, value, visit

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

close, nextValue, nextValue, valueSize, valueSize

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopHashMultimap

public HadoopHashMultimap(HadoopJobInfo jobInfo,
                          GridUnsafeMemory mem,
                          int cap)

Parameters:

jobInfo - Job info.

mem - Memory.

cap - Initial capacity.

Method Detail

startAdding

public HadoopMultimap.Adder startAdding(HadoopTaskContext ctx)
                                 throws IgniteCheckedException

Parameters:

ctx - Task context.

Returns:

Adder.

Throws:

IgniteCheckedException - If failed.

keys

public int keys()

Returns:

Keys count.

capacity

public int capacity()

Specified by:

capacity in class HadoopHashMultimapBase

Returns:

Hash table capacity.

meta

protected long meta(int idx)

Specified by:

meta in class HadoopHashMultimapBase

Parameters:

idx - Index in hash table.

Returns:

Meta page pointer.