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

Class HadoopHashMultimapBase

java.lang.Object

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

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

All Implemented Interfaces:

AutoCloseable, HadoopMultimap

Direct Known Subclasses:

HadoopConcurrentHashMultimap, HadoopHashMultimap

public abstract class HadoopHashMultimapBase
extends HadoopMultimapBase

Base class for hash multimaps.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	HadoopHashMultimapBase.Input Task input.
protected class	HadoopHashMultimapBase.Reader Reader for key and value.

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

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

Method Summary

Modifier and Type	Method and Description
abstract int	capacity()
protected long	collision(long meta)
protected void	collision(long meta, long collision)
HadoopTaskInput	input(HadoopTaskContext taskCtx)
protected long	key(long meta)
protected int	keyHash(long meta)
protected int	keySize(long meta)
protected abstract long	meta(int idx)
protected long	value(long meta)
protected void	value(long meta, long val)
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

close, nextValue, nextValue, valueSize, valueSize

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

startAdding

Constructor Detail

HadoopHashMultimapBase

protected HadoopHashMultimapBase(HadoopJobInfo jobInfo,
                                 GridUnsafeMemory mem)

Parameters:

jobInfo - Job info.

mem - Memory.

Method Detail

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

input

public HadoopTaskInput input(HadoopTaskContext taskCtx)
                      throws IgniteCheckedException

Parameters:

taskCtx - Task context.

Returns:

Task input.

Throws:

IgniteCheckedException - If failed.

capacity

public abstract int capacity()

Returns:

Hash table capacity.

meta

protected abstract long meta(int idx)

Parameters:

idx - Index in hash table.

Returns:

Meta page pointer.

keyHash

protected int keyHash(long meta)

Parameters:

meta - Meta pointer.

Returns:

Key hash.

keySize

protected int keySize(long meta)

Parameters:

meta - Meta pointer.

Returns:

Key size.

key

protected long key(long meta)

Parameters:

meta - Meta pointer.

Returns:

Key pointer.

value

protected long value(long meta)

Parameters:

meta - Meta pointer.

Returns:

Value pointer.

value

protected void value(long meta,
                     long val)

Parameters:

meta - Meta pointer.

val - Value pointer.

collision

protected long collision(long meta)

Parameters:

meta - Meta pointer.

Returns:

Collision pointer.

collision

protected void collision(long meta,
                         long collision)

Parameters:

meta - Meta pointer.

collision - Collision pointer.