com.marklogic.mapreduce.utilities

Class StatisticalAssignmentPolicy

java.lang.Object

com.marklogic.mapreduce.utilities.AssignmentPolicy

com.marklogic.mapreduce.utilities.StatisticalAssignmentPolicy

Direct Known Subclasses:

QueryAssignmentPolicy, RangeAssignmentPolicy

public class StatisticalAssignmentPolicy
extends AssignmentPolicy

Statistical Assignment Policy for fastload

Nested Class Summary

Nested classes/interfaces inherited from class com.marklogic.mapreduce.utilities.AssignmentPolicy

AssignmentPolicy.Kind

Field Summary

Fields inherited from class com.marklogic.mapreduce.utilities.AssignmentPolicy

LOG, policy, uForests

Constructor Summary

Constructors

Constructor and Description
StatisticalAssignmentPolicy(long[] stats, int batch)

Method Summary

Modifier and Type	Method and Description
int	getPlacementForestIndex(DocumentURI uri) get the index of the forest with smallest number of docs
void	updateStats(int fIdx, long count) add count to forest with index fIdx, which may not be the forest with minimum frmtCount.

Methods inherited from class com.marklogic.mapreduce.utilities.AssignmentPolicy

getPolicyKind

Methods inherited from class java.lang.Object

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

Constructor Detail

StatisticalAssignmentPolicy

public StatisticalAssignmentPolicy(long[] stats,
                                   int batch)

Method Detail

updateStats

public void updateStats(int fIdx,
                        long count)

add count to forest with index fIdx, which may not be the forest with minimum frmtCount. Used by fragment count rollback.

Parameters:

fIdx -

count -

getPlacementForestIndex

public int getPlacementForestIndex(DocumentURI uri)

get the index of the forest with smallest number of docs

Specified by:

getPlacementForestIndex in class AssignmentPolicy