Package com.evolveum.midpoint.schema.util.task

Class BucketingUtil

java.lang.Object

com.evolveum.midpoint.schema.util.task.BucketingUtil

public class BucketingUtil
extends Object

Methods related to bucketing part of an activity state and activity distribution definition.

Constructor Summary

Constructors

Constructor	Description
BucketingUtil()

Method Summary

Modifier and Type	Method	Description
static WorkBucketType	findBucketByNumber(List<WorkBucketType> buckets, int sequentialNumber)
static @NotNull WorkBucketType	findBucketByNumberRequired(List<WorkBucketType> buckets, int sequentialNumber)
static @NotNull List<WorkBucketType>	getBuckets(@NotNull ActivityStateType state)
static @NotNull List<WorkBucketType>	getBuckets(@NotNull TaskActivityStateType taskState, @NotNull ActivityPath activityPath)
static int	getCompleteBucketsNumber(@NotNull List<WorkBucketType> buckets)	Returns the number of buckets that are marked as COMPLETE.
static @Nullable WorkBucketType	getLastBucket(List<WorkBucketType> buckets)
static Integer	getNumberOfBuckets(@NotNull ActivityStateType state)
static @NotNull Set<Integer>	getSequentialNumbers(@NotNull Collection<WorkBucketType> buckets)
static @Nullable String	getWorkerOid(@NotNull WorkBucketType bucket)
static @Nullable AbstractWorkSegmentationType	getWorkSegmentationConfiguration(BucketsDefinitionType buckets)
static boolean	hasLimitations(WorkBucketType bucket)
static boolean	hasNonTrivialBuckets(@NotNull ActivityStateType state)	A little guesswork for now.
static boolean	isCoordinator(@Nullable ActivityStateType state)
static boolean	isDelegatedTo(@NotNull WorkBucketType bucket, @NotNull String workerOid)
static boolean	isInScavengingPhase(TaskActivityStateType taskState, ActivityPath activityPath)
static boolean	isScavenger(TaskActivityStateType taskState, ActivityPath activityPath)
static boolean	isStandalone(@Nullable ActivityStateType state)
static boolean	isWorkComplete(ActivityStateType state)
static void	sortBucketsBySequentialNumber(List<WorkBucketType> buckets)

Methods inherited from class java.lang.Object

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

Constructor Details

BucketingUtil

public BucketingUtil()

Method Details

findBucketByNumber

public static WorkBucketType findBucketByNumber(List<WorkBucketType> buckets,
 int sequentialNumber)

findBucketByNumberRequired

@NotNull
public static @NotNull WorkBucketType findBucketByNumberRequired(List<WorkBucketType> buckets,
 int sequentialNumber)

sortBucketsBySequentialNumber

public static void sortBucketsBySequentialNumber(List<WorkBucketType> buckets)

getWorkSegmentationConfiguration

@Nullable
public static @Nullable AbstractWorkSegmentationType getWorkSegmentationConfiguration(BucketsDefinitionType buckets)

getCompleteBucketsNumber

public static int getCompleteBucketsNumber(@NotNull
 @NotNull List<WorkBucketType> buckets)

Returns the number of buckets that are marked as COMPLETE. They may be implicitly present.

getLastBucket

@Nullable
public static @Nullable WorkBucketType getLastBucket(List<WorkBucketType> buckets)

hasLimitations

public static boolean hasLimitations(WorkBucketType bucket)

isCoordinator

public static boolean isCoordinator(@Nullable
 @Nullable ActivityStateType state)

isStandalone

public static boolean isStandalone(@Nullable
 @Nullable ActivityStateType state)

getBuckets

@NotNull
public static @NotNull List<WorkBucketType> getBuckets(@NotNull
 @NotNull TaskActivityStateType taskState,
 @NotNull
 @NotNull ActivityPath activityPath)

getBuckets

@NotNull
public static @NotNull List<WorkBucketType> getBuckets(@NotNull
 @NotNull ActivityStateType state)

getNumberOfBuckets

public static Integer getNumberOfBuckets(@NotNull
 @NotNull ActivityStateType state)

hasNonTrivialBuckets

public static boolean hasNonTrivialBuckets(@NotNull
 @NotNull ActivityStateType state)

A little guesswork for now.

isScavenger

public static boolean isScavenger(TaskActivityStateType taskState,
 ActivityPath activityPath)

isInScavengingPhase

public static boolean isInScavengingPhase(TaskActivityStateType taskState,
 ActivityPath activityPath)

isWorkComplete

public static boolean isWorkComplete(ActivityStateType state)

getWorkerOid

@Nullable
public static @Nullable String getWorkerOid(@NotNull
 @NotNull WorkBucketType bucket)

isDelegatedTo

public static boolean isDelegatedTo(@NotNull
 @NotNull WorkBucketType bucket,
 @NotNull
 @NotNull String workerOid)

getSequentialNumbers

@NotNull
public static @NotNull Set<Integer> getSequentialNumbers(@NotNull
 @NotNull Collection<WorkBucketType> buckets)