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

Class HadoopOffheapBuffer

java.lang.Object

org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopOffheapBuffer

public class HadoopOffheapBuffer
extends Object

Offheap buffer.

Constructor Summary

Constructors

Constructor and Description
HadoopOffheapBuffer(long bufPtr, long bufSize)

Method Summary

Modifier and Type	Method and Description
long	begin()
long	capacity()
boolean	isInside(long ptr)
long	move(long size)
long	moveBackward(long size)
long	pointer()
void	pointer(long ptr)
long	remaining()
void	reset() Resets position to the beginning of buffer.
void	set(long bufPtr, long bufSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopOffheapBuffer

public HadoopOffheapBuffer(long bufPtr,
                           long bufSize)

Parameters:

bufPtr - Pointer to buffer begin.

bufSize - Size of the buffer.

Method Detail

set

public void set(long bufPtr,
                long bufSize)

Parameters:

bufPtr - Pointer to buffer begin.

bufSize - Size of the buffer.

begin

public long begin()

Returns:

Pointer to internal buffer begin.

capacity

public long capacity()

Returns:

Buffer capacity.

remaining

public long remaining()

Returns:

Remaining capacity.

pointer

public long pointer()

Returns:

Absolute pointer to the current position inside of the buffer.

pointer

public void pointer(long ptr)

Parameters:

ptr - Absolute pointer to the current position inside of the buffer.

move

public long move(long size)

Parameters:

size - Size move on.

Returns:

Old position pointer or 0 if move goes beyond the end of the buffer.

moveBackward

public long moveBackward(long size)

Parameters:

size - Size move on.

Returns:

Old position pointer or 0 if move goes beyond the begin of the buffer.

isInside

public boolean isInside(long ptr)

Parameters:

ptr - Pointer.

Returns:

true If the given pointer is inside of this buffer.

reset

public void reset()

Resets position to the beginning of buffer.