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

Class HadoopMultimapBase.AdderBase

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, HadoopTaskOutput, HadoopMultimap.Adder

Enclosing class:

HadoopMultimapBase

protected abstract class HadoopMultimapBase.AdderBase
extends Object
implements HadoopMultimap.Adder

Base class for adders.

Field Summary

Fields

Modifier and Type	Field and Description
protected HadoopSerialization	keySer
protected HadoopSerialization	valSer

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AdderBase(HadoopTaskContext ctx)

Method Summary

Modifier and Type	Method and Description
HadoopMultimap.Key	addKey(DataInput in, HadoopMultimap.Key reuse)
protected long	allocate(int size)
void	close()
protected void	localDeallocate(long ptr) Rewinds local allocation pointer to the given pointer if possible.
protected long	write(int off, Object o, HadoopSerialization ser)
protected int	writtenSize()

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.HadoopTaskOutput

write

Field Detail

keySer

protected final HadoopSerialization keySer

valSer

protected final HadoopSerialization valSer

Constructor Detail

AdderBase

protected AdderBase(HadoopTaskContext ctx)
             throws IgniteCheckedException

Parameters:

ctx - Task context.

Throws:

IgniteCheckedException - If failed.

Method Detail

write

protected long write(int off,
                     Object o,
                     HadoopSerialization ser)
              throws IgniteCheckedException

Parameters:

off - Offset.

o - Object.

Returns:

Page pointer.

Throws:

IgniteCheckedException - If failed.

allocate

protected long allocate(int size)

Parameters:

size - Size.

Returns:

Pointer.

localDeallocate

protected void localDeallocate(long ptr)

Rewinds local allocation pointer to the given pointer if possible.

Parameters:

ptr - Pointer.

writtenSize

protected int writtenSize()

Returns:

Written size.

addKey

public HadoopMultimap.Key addKey(DataInput in,
                                 @Nullable
                                 HadoopMultimap.Key reuse)
                          throws IgniteCheckedException

Specified by:

addKey in interface HadoopMultimap.Adder

Parameters:

in - Data input.

reuse - Reusable key.

Returns:

Key.

Throws:

IgniteCheckedException - If failed.

close

public void close()
           throws IgniteCheckedException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface HadoopTaskOutput

Throws:

IgniteCheckedException