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

Interface HadoopMultimap

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

HadoopConcurrentHashMultimap, HadoopHashMultimap, HadoopHashMultimapBase, HadoopMultimapBase, HadoopSkipList

public interface HadoopMultimap
extends AutoCloseable

Multimap for hadoop intermediate results.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	HadoopMultimap.Adder Adder.
static interface	HadoopMultimap.Key Key add values to.
static interface	HadoopMultimap.Value Value.
static interface	HadoopMultimap.Visitor Key and values visitor.

Method Summary

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

Method Detail

visit

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

HadoopMultimap.Adder startAdding(HadoopTaskContext ctx)
                          throws IgniteCheckedException

Parameters:

ctx - Task context.

Returns:

Adder.

Throws:

IgniteCheckedException - If failed.

input

HadoopTaskInput input(HadoopTaskContext taskCtx)
               throws IgniteCheckedException

Parameters:

taskCtx - Task context.

Returns:

Task input.

Throws:

IgniteCheckedException - If failed.

close

void close()

Specified by:

close in interface AutoCloseable