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

Class PlainIterativeActivityRun<I,WD extends WorkDefinition,AH extends ActivityHandler<WD,AH>,WS extends AbstractActivityWorkStateType>

java.lang.Object

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

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

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

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

Type Parameters:

I - Items being processed.

WD - Work definition type.

AH - Activity handler type.

WS - Work (business) state type.

All Implemented Interfaces:

ImplicitSegmentationResolver, IterativeActivityRunSpecifics, PlainIterativeActivityRunSpecifics<I>, ItemProcessor<I>, ExecutionSupport, DebugDumpable

Direct Known Subclasses:

AsyncUpdateActivityRun, LiveSyncActivityRun

public abstract class PlainIterativeActivityRun<I,WD extends WorkDefinition,AH extends ActivityHandler<WD,AH>,WS extends AbstractActivityWorkStateType>
extends IterativeActivityRun<I,WD,AH,WS>
implements PlainIterativeActivityRunSpecifics<I>

Run of a plain iterative activity. Basically, here we implement abstract methods of IterativeActivityRun generally either by doing nothing or delegating to PlainIterativeActivityRunSpecifics instance.

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.IterativeActivityRun

beans, bucket, coordinator, errorState, transientRunStatistics

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
PlainIterativeActivityRun(@NotNull ActivityRunInstantiationContext<WD,AH> context, @NotNull String shortNameCapitalized)

Method Summary

Modifier and Type	Method	Description
protected boolean	isInRepository(OperationResult result)	We simply do not support repository-related item-counting options in plain-iterative activity runs.
protected void	prepareItemSourceForCurrentBucket(OperationResult result)	Prepares the item source.

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

canUpdateThreadLocalStatistics, determineActivityStateForCounters, determineCurrentBucketSize, determineOverallSize, disableGlobalConnIdOperationsListener, enableGlobalConnIdOperationsListener, ensureNoParallelism, ensureNoWorkerThreads, getBucket, getChannelOverride, getConnIdOperationsReport, getContextDescription, getContextDescriptionSpaced, getDefaultErrorAction, getErrorState, getItemsReport, getRootTaskOid, getShortName, getTransientRunStatistics, handleError, isMultithreaded, iterateOverItemsInBucket, processItem, runLocally, setContextDescription, shouldReportConnIdOperations, shouldReportInternalOperations, shouldReportItems, updateStatistics

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

createReportingCharacteristics, getCurrentResultStatusBean, getDesiredTaskObjectRef, getSimulationTransaction, getTaskExecutionMode, isExcludedFromStalenessChecking, runInternal, shouldUpdateProgressInStateOverview, updateItemProgressInTreeOverviewIfTimePassed

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

areActionsExecutedStatisticsSupported, areRunRecordsSupported, areStatisticsSupported, areSynchronizationStatisticsSupported, canRun, debugDump, debugDumpExtra, determineActivityStateDefinition, 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

Methods inherited from interface com.evolveum.midpoint.task.api.ExecutionSupport

getActivityExecutionMode, getActivityPath, incrementCounters, recordIterativeOperationStart

Methods inherited from interface com.evolveum.midpoint.repo.common.activity.run.processing.ItemProcessor

processItem

Methods inherited from interface com.evolveum.midpoint.repo.common.activity.run.IterativeActivityRunSpecifics

afterBucketProcessing, afterRun, beforeBucketProcessing, beforeRun, createReportingCharacteristics, resolveImplicitSegmentation, useOtherActivityStateForCounters

Methods inherited from interface com.evolveum.midpoint.repo.common.activity.run.PlainIterativeActivityRunSpecifics

determineCurrentBucketSize, determineOverallSize, getDefaultErrorAction, iterateOverItemsInBucket

Constructor Details

PlainIterativeActivityRun

public PlainIterativeActivityRun(@NotNull
 @NotNull ActivityRunInstantiationContext<WD,AH> context,
 @NotNull
 @NotNull String shortNameCapitalized)

Method Details

prepareItemSourceForCurrentBucket

protected void prepareItemSourceForCurrentBucket(OperationResult result)

Description copied from class: IterativeActivityRun

Prepares the item source. E.g. for search-iterative tasks we prepare object type, query, and options here. Iterative activities delegate this method fully to the plugin. However, search-based activities provide their own default implementation.

Specified by:

prepareItemSourceForCurrentBucket in class IterativeActivityRun<I,WD extends WorkDefinition,AH extends ActivityHandler<WD,AH>,WS extends AbstractActivityWorkStateType>

isInRepository

protected boolean isInRepository(OperationResult result)

We simply do not support repository-related item-counting options in plain-iterative activity runs.

Specified by:

isInRepository in class IterativeActivityRun<I,WD extends WorkDefinition,AH extends ActivityHandler<WD,AH>,WS extends AbstractActivityWorkStateType>