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

Class HadoopMultimapBase.ReaderBase

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

HadoopHashMultimapBase.Reader

Enclosing class:

HadoopMultimapBase

protected class HadoopMultimapBase.ReaderBase
extends Object
implements AutoCloseable

Reader for key and value.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ReaderBase(HadoopSerialization ser)

Method Summary

Modifier and Type	Method and Description
void	close()
protected Object	read(long ptr, long size)
Object	readValue(long valPtr)
void	resetReusedObject(Object tmp) Resets temporary object to the given one.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReaderBase

protected ReaderBase(HadoopSerialization ser)

Parameters:

ser - Serialization.

Method Detail

readValue

public Object readValue(long valPtr)

Parameters:

valPtr - Value page pointer.

Returns:

Value.

resetReusedObject

public void resetReusedObject(Object tmp)

Resets temporary object to the given one.

Parameters:

tmp - Temporary object for reuse.

read

protected Object read(long ptr,
                      long size)
               throws IgniteCheckedException

Parameters:

ptr - Pointer.

size - Object size.

Returns:

Object.

Throws:

IgniteCheckedException

close

public void close()
           throws IgniteCheckedException

Specified by:

close in interface AutoCloseable

Throws:

IgniteCheckedException