Progeneric.Ptl.Tasks

Class Partitioner64

java.lang.Object

Progeneric.Ptl.Tasks.Partitioner64

public class Partitioner64
extends java.lang.Object

Provides common partitioning strategies for ranges in a thread safe mode.

Field Summary

Fields

Modifier and Type	Field and Description
long	last The value addressing the position one past the final element in the range.
int	size The size of the partition.

Constructor Summary

Constructors

Constructor and Description
Partitioner64(long first, long last) Constructs a Partitioner64 object from the specified range with the default partition size equal to 1.
Partitioner64(long first, long last, int partitionSize) Constructs a Partitioner64 object from the specified range using the specified partition size.

Method Summary

Methods

Modifier and Type	Method and Description
long	GetIndex() Gets the current index before it is incremented in a thread safe mode.
long	GetIndex(int taskId) Gets the current index before it is incremented in a thread safe mode for the specified task.
Tuple2<java.lang.Long,java.lang.Long>	GetPartition() Gets the current partition before it is incremented in a thread safe mode.

Methods inherited from class java.lang.Object

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

Field Detail

size

public final int size

The size of the partition. The default value is 1.

last

public final long last

The value addressing the position one past the final element in the range.

Constructor Detail

Partitioner64

public Partitioner64(long first,
             long last)

Constructs a Partitioner64 object from the specified range with the default partition size equal to 1.

Parameters:

first - An integer addressing the position of the first element in the range.

last - An integer addressing the position one past the final element in the range.

Partitioner64

public Partitioner64(long first,
             long last,
             int partitionSize)

Constructs a Partitioner64 object from the specified range using the specified partition size.

Parameters:

first - An integer addressing the position of the first element in the range.

last - An integer addressing the position one past the final element in the range.

partitionSize - The specified partition size.

Method Detail

GetIndex

public long GetIndex()

Gets the current index before it is incremented in a thread safe mode.

Remarks: The current index is not incremented anymore if it is equal to last.

Returns:

The current index before it is incremented.

GetIndex

public long GetIndex(int taskId)

Gets the current index before it is incremented in a thread safe mode for the specified task.

Remarks: The current index is not incremented anymore if it is equal to last.

Parameters:

taskId - The specified task.

Returns:

The current index before it is incremented.

GetPartition

public Tuple2<java.lang.Long,java.lang.Long> GetPartition()

Gets the current partition before it is incremented in a thread safe mode.

Remarks: The current partition is not incremented anymore if it is equal to (last, last).

Returns:

The current partition before it is incremented.