Package com.evolveum.midpoint.repo.common.activity.run

Class DistributingActivityRun<WD extends WorkDefinition,AH extends ActivityHandler<WD,AH>,WS extends AbstractActivityWorkStateType>

java.lang.Object

com.evolveum.midpoint.repo.common.activity.run.AbstractActivityRun<WD,AH,WS>

com.evolveum.midpoint.repo.common.activity.run.DistributingActivityRun<WD,AH,WS>

Type Parameters:

WD - work definition

AH - activity handler

All Implemented Interfaces:

ExecutionSupport, DebugDumpable

public final class DistributingActivityRun<WD extends WorkDefinition,AH extends ActivityHandler<WD,AH>,WS extends AbstractActivityWorkStateType>
extends AbstractActivityRun<WD,AH,WS>

An activity that distributes (usually bucketed) activity to a set of worker tasks. What is interesting is that this activity can maintain a work state of the type belonging to activity being distributed.

Nested Class Summary

Nested classes/interfaces inherited from interface com.evolveum.midpoint.task.api.ExecutionSupport

ExecutionSupport.CountersGroup

Field Summary

Fields inherited from class com.evolveum.midpoint.repo.common.activity.run.AbstractActivityRun

activity, activityState, endTimestamp, startTimestamp, taskRun

Fields inherited from interface com.evolveum.midpoint.util.DebugDumpable

INDENT_STRING

Constructor Summary

Constructors

Constructor	Description
DistributingActivityRun(@NotNull ActivityRunInstantiationContext<WD,AH> context)

Method Summary

Modifier and Type	Method	Description
@NotNull ActivityReportingCharacteristics	createReportingCharacteristics()	This method should be called only after the concrete instance is fully initialized.
protected void	debugDumpExtra(StringBuilder sb, int indent)
protected @NotNull ActivityRunResult	runInternal(OperationResult result)	Carries out the actual run of this activity.

Methods inherited from class com.evolveum.midpoint.repo.common.activity.run.AbstractActivityRun

areActionsExecutedStatisticsSupported, areRunRecordsSupported, areStatisticsSupported, areSynchronizationStatisticsSupported, canRun, debugDump, determineActivityStateDefinition, determineActivityStateForCounters, ensureFullExecution, ensureNoDryRun, ensureNoPreviewNorDryRun, getActivity, getActivityDefinition, getActivityExecutionMode, getActivityHandler, getActivityPath, getActivityState, getActivityStateDefinition, getBeans, getItemsProcessed, getLocalParentRun, getReportingCharacteristics, getRunningTask, getStartTimestampRequired, getTaskRun, getTreeStateOverview, getWorkDefinition, incrementCounters, incrementProgress, isBucketAnalysis, isDryRun, isFullExecution, isNoExecution, isNonScavengingWorker, isProgressSupported, isWorker, onActivityRealizationComplete, onActivityRealizationStart, recordIterativeOperationStart, run, setInstanceReady, shouldCreateWorkStateOnInitialization, standardRunResult, standardRunResult, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.evolveum.midpoint.util.DebugDumpable

debugDump, debugDumpLazily, debugDumpLazily

Constructor Details

DistributingActivityRun

public DistributingActivityRun(@NotNull
 @NotNull ActivityRunInstantiationContext<WD,AH> context)

Method Details

createReportingCharacteristics

@NotNull
public @NotNull ActivityReportingCharacteristics createReportingCharacteristics()

Description copied from class: AbstractActivityRun

This method should be called only after the concrete instance is fully initialized.

Overrides:

createReportingCharacteristics in class AbstractActivityRun<WD extends WorkDefinition,AH extends ActivityHandler<WD,AH>,WS extends AbstractActivityWorkStateType>

runInternal

@NotNull
protected @NotNull ActivityRunResult runInternal(OperationResult result)
                                          throws ActivityRunException

Description copied from class: AbstractActivityRun

Carries out the actual run of this activity.

Specified by:

runInternal in class AbstractActivityRun<WD extends WorkDefinition,AH extends ActivityHandler<WD,AH>,WS extends AbstractActivityWorkStateType>

Throws:

ActivityRunException

debugDumpExtra

protected void debugDumpExtra(StringBuilder sb,
 int indent)

Overrides:

debugDumpExtra in class AbstractActivityRun<WD extends WorkDefinition,AH extends ActivityHandler<WD,AH>,WS extends AbstractActivityWorkStateType>