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

Class HadoopHashMultimapBase.Input

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, HadoopTaskInput

Enclosing class:

HadoopHashMultimapBase

protected class HadoopHashMultimapBase.Input
extends Object
implements HadoopTaskInput

Task input.

Constructor Summary

Constructors

Constructor and Description
Input(HadoopTaskContext taskCtx)

Method Summary

Modifier and Type	Method and Description
void	close()
Object	key()
boolean	next()
Iterator<?>	values()

Methods inherited from class java.lang.Object

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

Constructor Detail

Input

public Input(HadoopTaskContext taskCtx)
      throws IgniteCheckedException

Parameters:

taskCtx - Task context.

Throws:

IgniteCheckedException - If failed.

Method Detail

next

public boolean next()

Specified by:

next in interface HadoopTaskInput

key

public Object key()

Specified by:

key in interface HadoopTaskInput

values

public Iterator<?> values()

Specified by:

values in interface HadoopTaskInput

close

public void close()
           throws IgniteCheckedException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface HadoopTaskInput

Throws:

IgniteCheckedException