Package com.evolveum.midpoint.model.impl.sync.tasks.imp

Class AbstractImportActivityRun<WD extends ResourceSetTaskWorkDefinition,AH extends ModelActivityHandler<WD,AH>>

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<C,WD,AH,WS>

com.evolveum.midpoint.repo.common.activity.run.SearchBasedActivityRun<ShadowType,WD,AH,AbstractActivityWorkStateType>

com.evolveum.midpoint.model.impl.sync.tasks.imp.AbstractImportActivityRun<WD,AH>

All Implemented Interfaces:

ImplicitSegmentationResolver, IterativeActivityRunSpecifics, SearchBasedActivityRunSpecifics<ShadowType>, ExecutionSupport, DebugDumpable

Direct Known Subclasses:

ImportActivityRun, ReclassificationActivityRun

public abstract class AbstractImportActivityRun<WD extends ResourceSetTaskWorkDefinition,AH extends ModelActivityHandler<WD,AH>>
extends SearchBasedActivityRun<ShadowType,WD,AH,AbstractActivityWorkStateType>

Abstract class for runner of tasks based on import (import and shadow reclassification).

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

searchSpecification

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

Modifier	Constructor	Description
protected	AbstractImportActivityRun(ActivityRunInstantiationContext<WD,AH> context, @NotNull String shortNameCapitalized)

Method Summary

Modifier and Type	Method	Description
void	beforeRun(OperationResult result)	Called before the run.
ItemDefinitionProvider	createItemDefinitionProvider()	Returns a provider of definitions for runtime items (e.g.
@NotNull ActivityReportingCharacteristics	createReportingCharacteristics()	This method should be called only after the concrete instance is fully initialized.
void	customizeSearchOptions(SearchSpecification<ShadowType> searchSpecification, OperationResult result)	Customizes search options present in the original search specification (usually derived from the task configuration).
protected @NotNull ObjectReferenceType	getDesiredTaskObjectRef()	Returns the value that should be put into task.objectRef.
protected abstract QName	getSourceChannel()
protected Collection<SelectorOptions<GetOperationOptions>>	mergeSearchOptions(Collection<SelectorOptions<GetOperationOptions>> defaultOptions, Collection<SelectorOptions<GetOperationOptions>> searchOptions)
boolean	processItem(@NotNull ShadowType object, @NotNull ItemProcessingRequest<ShadowType> request, RunningTask workerTask, OperationResult result)	Processes given item that came as part of a request.

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

countObjects, determineCurrentBucketSize, determineOverallSize, getDefaultErrorAction, getItemType, getQuery, getSchemaService, getSearchOptions, getSearchSpecificationRequired, getTaskManager, isInRepository, iterateOverItemsInBucket, prepareItemSourceForCurrentBucket, processItem

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

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

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

getCurrentResultStatusBean, 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.IterativeActivityRunSpecifics

afterBucketProcessing, afterRun, beforeBucketProcessing, resolveImplicitSegmentation, useOtherActivityStateForCounters

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

createCustomSearchSpecification, customizeQuery, doesRequireDirectRepositoryAccess

Constructor Details

AbstractImportActivityRun

protected AbstractImportActivityRun(ActivityRunInstantiationContext<WD,AH> context,
 @NotNull
 @NotNull String shortNameCapitalized)

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.

Specified by:

createReportingCharacteristics in interface IterativeActivityRunSpecifics

Overrides:

createReportingCharacteristics in class LocalActivityRun<WD extends ResourceSetTaskWorkDefinition,AH extends ModelActivityHandler<WD,AH>,AbstractActivityWorkStateType>

Returns:

Reporting characteristics of the activity run. They e.g. provide default values for ActivityReportingDefinition.

beforeRun

public void beforeRun(OperationResult result)
               throws ActivityRunException,
CommonException

Description copied from interface: IterativeActivityRunSpecifics

Called before the run. Note that e.g. for search-based activities the search specification is *not* known at this moment.

Throws:

ActivityRunException

CommonException

getDesiredTaskObjectRef

@NotNull
protected @NotNull ObjectReferenceType getDesiredTaskObjectRef()

Description copied from class: LocalActivityRun

Returns the value that should be put into task.objectRef. Should be overridden by subclasses. It should be called _after_ IterativeActivityRunSpecifics.beforeRun(OperationResult) method, in order to give the execution a chance to prepare data for this method.

Overrides:

getDesiredTaskObjectRef in class LocalActivityRun<WD extends ResourceSetTaskWorkDefinition,AH extends ModelActivityHandler<WD,AH>,AbstractActivityWorkStateType>

getSourceChannel

protected abstract QName getSourceChannel()

customizeSearchOptions

public void customizeSearchOptions(SearchSpecification<ShadowType> searchSpecification,
 OperationResult result)

Description copied from interface: SearchBasedActivityRunSpecifics

Customizes search options present in the original search specification (usually derived from the task configuration). The activity can either add or modify some options in the provided object - if it's not null - or replace the whole object by its own version.

mergeSearchOptions

protected Collection<SelectorOptions<GetOperationOptions>> mergeSearchOptions(Collection<SelectorOptions<GetOperationOptions>> defaultOptions,
 Collection<SelectorOptions<GetOperationOptions>> searchOptions)

createItemDefinitionProvider

public ItemDefinitionProvider createItemDefinitionProvider()

Description copied from interface: SearchBasedActivityRunSpecifics

Returns a provider of definitions for runtime items (e.g. attributes) that are needed in bucket filters. Usually needed for activities that work with resource objects.

processItem

public boolean processItem(@NotNull
 @NotNull ShadowType object,
 @NotNull
 @NotNull ItemProcessingRequest<ShadowType> request,
 RunningTask workerTask,
 OperationResult result)
                    throws CommonException,
ActivityRunException

Description copied from interface: SearchBasedActivityRunSpecifics

Processes given item that came as part of a request. BEWARE: Item may have been preprocessed, and may be different from the item present in the request.

Throws:

CommonException

ActivityRunException