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

Class ActivityItemProcessingStatisticsUtil

java.lang.Object

com.evolveum.midpoint.schema.util.task.ActivityItemProcessingStatisticsUtil

public class ActivityItemProcessingStatisticsUtil
extends Object

Constructor Summary

Constructors

Constructor	Description
ActivityItemProcessingStatisticsUtil()

Method Summary

Modifier and Type	Method	Description
static <T> T	add(List<T> list, T value)	Like List.add(Object) but returns the value.
static void	addTo(@NotNull ActivityItemProcessingStatisticsType sum, @Nullable ActivityItemProcessingStatisticsType delta)	Updates specified summary with given delta.
static String	format(@Nullable ActivityItemProcessingStatisticsType source)
static String	format(@Nullable ActivityItemProcessingStatisticsType source, AbstractStatisticsPrinter.Options options)	Formats the information.
static int	getErrors(Collection<ActivityStateType> states)
static int	getErrorsShallow(ActivityItemProcessingStatisticsType info)
static ActivityItemProcessingStatisticsType	getItemProcessingStatistics(ActivityStateType state)
static List<ActivityItemProcessingStatisticsType>	getItemProcessingStatisticsFromStates(@NotNull Collection<ActivityStateType> states)
static int	getItemsProcessed(@NotNull Collection<ActivityStateType> states)
static int	getItemsProcessed(ActivityItemProcessingStatisticsType itemProcessingStatistics)
static int	getItemsProcessedShallow(ActivityItemProcessingStatisticsType info)
static int	getItemsProcessedWithFailure(@NotNull Collection<ActivityStateType> states)
static int	getItemsProcessedWithFailure(ActivityItemProcessingStatisticsType info)
static int	getItemsProcessedWithFailureShallow(ActivityItemProcessingStatisticsType info)
static int	getItemsProcessedWithSkip(ActivityItemProcessingStatisticsType info)
static int	getItemsProcessedWithSkipShallow(ActivityItemProcessingStatisticsType info)
static int	getItemsProcessedWithSuccess(ActivityItemProcessingStatisticsType info)
static int	getItemsProcessedWithSuccessShallow(ActivityItemProcessingStatisticsType info)
static String	getLastProcessedItemMessage(ActivityItemProcessingStatisticsType info, Predicate<ProcessedItemSetType> itemSetFilter)	Returns message about the item that was last processed by given task in item set defined by the filter.
static String	getLastProcessedObjectName(ActivityItemProcessingStatisticsType info, Predicate<ProcessedItemSetType> itemSetFilter)	Returns object that was last processed by given task in item set defined by the filter.
static String	getLastProcessedObjectOid(ActivityItemProcessingStatisticsType info, Predicate<ProcessedItemSetType> itemSetFilter)	Returns object OID that was last processed by given task in item set defined by the filter.
static String	getLastSuccessObjectName(@NotNull TaskType task)	Returns object that was last successfully processed by given physical task.
static String	getLastSuccessObjectName(ActivityItemProcessingStatisticsType stats)
static double	getProcessingTime(@NotNull Collection<ActivityStateType> states)
static double	getProcessingTime(ActivityItemProcessingStatisticsType info)
static @NotNull ActivityItemProcessingStatisticsType	getSummarizedStatistics(@Nullable TaskActivityStateType taskActivityState)
static boolean	hasItemProcessingInformation(@NotNull ActivityTreeUtil.ActivityStateInContext cState)
static boolean	hasItemProcessingInformation(@Nullable ActivityStateType state)
static @NotNull ActivityItemProcessingStatisticsType	summarize(@NotNull Collection<ActivityItemProcessingStatisticsType> deltas)
static @NotNull ActivityItemProcessingStatisticsType	summarize(@NotNull Stream<ActivityItemProcessingStatisticsType> deltas)
static Double	toSeconds(Long time)

Methods inherited from class java.lang.Object

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

Constructor Detail

ActivityItemProcessingStatisticsUtil

public ActivityItemProcessingStatisticsUtil()

Method Detail

getItemsProcessedWithFailure

public static int getItemsProcessedWithFailure(ActivityItemProcessingStatisticsType info)

getItemsProcessedWithSuccess

public static int getItemsProcessedWithSuccess(ActivityItemProcessingStatisticsType info)

getItemsProcessedWithSkip

public static int getItemsProcessedWithSkip(ActivityItemProcessingStatisticsType info)

getItemsProcessedWithFailureShallow

public static int getItemsProcessedWithFailureShallow(ActivityItemProcessingStatisticsType info)

getItemsProcessedWithSuccessShallow

public static int getItemsProcessedWithSuccessShallow(ActivityItemProcessingStatisticsType info)

getItemsProcessedWithSkipShallow

public static int getItemsProcessedWithSkipShallow(ActivityItemProcessingStatisticsType info)

getItemsProcessedShallow

public static int getItemsProcessedShallow(ActivityItemProcessingStatisticsType info)

getItemsProcessed

public static int getItemsProcessed(ActivityItemProcessingStatisticsType itemProcessingStatistics)

getItemsProcessed

public static int getItemsProcessed(@NotNull
                                    @NotNull Collection<ActivityStateType> states)

getItemsProcessedWithFailure

public static int getItemsProcessedWithFailure(@NotNull
                                               @NotNull Collection<ActivityStateType> states)

getItemProcessingStatistics

public static ActivityItemProcessingStatisticsType getItemProcessingStatistics(ActivityStateType state)

getErrorsShallow

public static int getErrorsShallow(ActivityItemProcessingStatisticsType info)

getErrors

public static int getErrors(Collection<ActivityStateType> states)

getProcessingTime

public static double getProcessingTime(ActivityItemProcessingStatisticsType info)

getProcessingTime

public static double getProcessingTime(@NotNull
                                       @NotNull Collection<ActivityStateType> states)

getLastProcessedObjectName

public static String getLastProcessedObjectName(ActivityItemProcessingStatisticsType info,
                                                Predicate<ProcessedItemSetType> itemSetFilter)

Returns object that was last processed by given task in item set defined by the filter. TODO this should operate on a tree!

getLastProcessedItemMessage

public static String getLastProcessedItemMessage(ActivityItemProcessingStatisticsType info,
                                                 Predicate<ProcessedItemSetType> itemSetFilter)

Returns message about the item that was last processed by given task in item set defined by the filter. TODO this should operate on a tree!

getLastProcessedObjectOid

public static String getLastProcessedObjectOid(ActivityItemProcessingStatisticsType info,
                                               Predicate<ProcessedItemSetType> itemSetFilter)

Returns object OID that was last processed by given task in item set defined by the filter. TODO this should operate on a tree!

getLastSuccessObjectName

public static String getLastSuccessObjectName(@NotNull
                                              @NotNull TaskType task)

Returns object that was last successfully processed by given physical task. TODO optimize (avoid full summarization)

getSummarizedStatistics

@NotNull
public static @NotNull ActivityItemProcessingStatisticsType getSummarizedStatistics(@Nullable
                                                                                    @Nullable TaskActivityStateType taskActivityState)

getLastSuccessObjectName

public static String getLastSuccessObjectName(ActivityItemProcessingStatisticsType stats)

toSeconds

public static Double toSeconds(Long time)

add

public static <T> T add(List<T> list,
                        T value)

Like List.add(Object) but returns the value.

getItemProcessingStatisticsFromStates

public static List<ActivityItemProcessingStatisticsType> getItemProcessingStatisticsFromStates(@NotNull
                                                                                               @NotNull Collection<ActivityStateType> states)

summarize

@NotNull
public static @NotNull ActivityItemProcessingStatisticsType summarize(@NotNull
                                                                      @NotNull Collection<ActivityItemProcessingStatisticsType> deltas)

summarize

@NotNull
public static @NotNull ActivityItemProcessingStatisticsType summarize(@NotNull
                                                                      @NotNull Stream<ActivityItemProcessingStatisticsType> deltas)

addTo

public static void addTo(@NotNull
                         @NotNull ActivityItemProcessingStatisticsType sum,
                         @Nullable
                         @Nullable ActivityItemProcessingStatisticsType delta)

Updates specified summary with given delta.

hasItemProcessingInformation

public static boolean hasItemProcessingInformation(@NotNull
                                                   @NotNull ActivityTreeUtil.ActivityStateInContext cState)

hasItemProcessingInformation

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

format

public static String format(@Nullable
                            @Nullable ActivityItemProcessingStatisticsType source)

format

public static String format(@Nullable
                            @Nullable ActivityItemProcessingStatisticsType source,
                            AbstractStatisticsPrinter.Options options)

Formats the information.