Class AbstractIterativeModelTaskPartExecution<O extends ObjectType,TH extends AbstractModelTaskHandler<TH,TE>,TE extends AbstractTaskExecution<TH,TE>,PE extends AbstractIterativeModelTaskPartExecution<O,TH,TE,PE,RH>,RH extends AbstractSearchIterativeItemProcessor<O,TH,TE,PE,RH>>
- java.lang.Object
-
- com.evolveum.midpoint.repo.common.task.AbstractIterativeTaskPartExecution<PrismObject<O>,TH,TE,PE,RH>
-
- com.evolveum.midpoint.repo.common.task.AbstractSearchIterativeTaskPartExecution<O,TH,TE,PE,RH>
-
- com.evolveum.midpoint.model.impl.tasks.AbstractIterativeModelTaskPartExecution<O,TH,TE,PE,RH>
-
- Direct Known Subclasses:
AbstractScannerTaskPartExecution
,ImportFromResourceTaskPartExecution
,ObjectIntegrityCheckTaskPartExecution
,ShadowIntegrityCheckTaskPartExecution
,SimpleIterativeTaskHandler.PartExecution
public abstract class AbstractIterativeModelTaskPartExecution<O extends ObjectType,TH extends AbstractModelTaskHandler<TH,TE>,TE extends AbstractTaskExecution<TH,TE>,PE extends AbstractIterativeModelTaskPartExecution<O,TH,TE,PE,RH>,RH extends AbstractSearchIterativeItemProcessor<O,TH,TE,PE,RH>> extends AbstractSearchIterativeTaskPartExecution<O,TH,TE,PE,RH>
Task part execution for model-level search-iterative tasks. Provides an implementation of functionality that is not present in repo-common (where root search-iterative functionality resides), like calling model for search/count operations, processing expressions in search queries, or authorizations.
-
-
Field Summary
-
Fields inherited from class com.evolveum.midpoint.repo.common.task.AbstractSearchIterativeTaskPartExecution
objectType, query, searchOptions, useRepository, workBucket
-
Fields inherited from class com.evolveum.midpoint.repo.common.task.AbstractIterativeTaskPartExecution
bucketStatistics, coordinator, itemProcessor, localCoordinatorTask, logger, reportingOptions, runResult, taskExecution, taskHandler
-
-
Constructor Summary
Constructors Constructor Description AbstractIterativeModelTaskPartExecution(TE ctx)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
checkRawAuthorization(Task task, OperationResult result)
protected Integer
countObjects(OperationResult opResult)
Used to count objects using model or any similar higher-level interface.protected @NotNull ObjectPreprocessor<O>
createShadowFetchingPreprocessor()
protected boolean
modelProcessingAvailable()
protected ObjectQuery
preProcessQuery(ObjectQuery query, OperationResult opResult)
Pre-processing query (e.g.protected void
searchIterative(OperationResult opResult)
Used to search using model or any similar higher-level interface.-
Methods inherited from class com.evolveum.midpoint.repo.common.task.AbstractSearchIterativeTaskPartExecution
countObjectsInRepository, createItemDefinitionProvider, createItemDefinitionProviderForAttributes, createQuery, createQueryFromTask, createQueryFromTaskIfExists, createSearchOptions, createSearchOptionsFromTask, createSearchResultHandler, determineObjectType, getDefaultErrorAction, getExpressionProfile, getPrismContext, getSchemaService, getSearchOptions, getTaskHandler, getTaskManager, getTypeFromTask, prepareItemSource, processItems, providesTracingAndDynamicProfiling, requiresDirectRepositoryAccess, searchIterativeInRepository, setExpectedTotal, setRequiresDirectRepositoryAccess
-
Methods inherited from class com.evolveum.midpoint.repo.common.task.AbstractIterativeTaskPartExecution
createItemProcessor, ensureNoWorkerThreads, finish, getContextDescription, getExpectedParts, getLogger, getPartNumber, getPartStartTimestamp, getPartUri, getProcessShortName, getProcessShortNameCapitalized, getReportingOptions, getRootTask, getRootTaskOid, getStartTimeMillis, getTaskExecution, heartbeat, initialize, isMultithreaded, isSimulate, run, setContextDescription, setExpectedParts, setPartNumber, setPartUri, setProcessShortNameCapitalized
-
-
-
-
Constructor Detail
-
AbstractIterativeModelTaskPartExecution
public AbstractIterativeModelTaskPartExecution(TE ctx)
-
-
Method Detail
-
preProcessQuery
protected ObjectQuery preProcessQuery(ObjectQuery query, OperationResult opResult) throws SchemaException, ObjectNotFoundException, ExpressionEvaluationException, CommunicationException, ConfigurationException, SecurityViolationException
Description copied from class:AbstractSearchIterativeTaskPartExecution
Pre-processing query (e.g. evaluate expressions).- Overrides:
preProcessQuery
in classAbstractSearchIterativeTaskPartExecution<O extends ObjectType,TH extends AbstractModelTaskHandler<TH,TE>,TE extends AbstractTaskExecution<TH,TE>,PE extends AbstractIterativeModelTaskPartExecution<O,TH,TE,PE,RH>,RH extends AbstractSearchIterativeItemProcessor<O,TH,TE,PE,RH>>
- Throws:
SchemaException
ObjectNotFoundException
ExpressionEvaluationException
CommunicationException
ConfigurationException
SecurityViolationException
-
countObjects
protected final Integer countObjects(OperationResult opResult) throws SchemaException, ObjectNotFoundException, CommunicationException, ConfigurationException, SecurityViolationException, ExpressionEvaluationException
Description copied from class:AbstractSearchIterativeTaskPartExecution
Used to count objects using model or any similar higher-level interface. Defaults to repository count.- Overrides:
countObjects
in classAbstractSearchIterativeTaskPartExecution<O extends ObjectType,TH extends AbstractModelTaskHandler<TH,TE>,TE extends AbstractTaskExecution<TH,TE>,PE extends AbstractIterativeModelTaskPartExecution<O,TH,TE,PE,RH>,RH extends AbstractSearchIterativeItemProcessor<O,TH,TE,PE,RH>>
- Throws:
SchemaException
ObjectNotFoundException
CommunicationException
ConfigurationException
SecurityViolationException
ExpressionEvaluationException
-
searchIterative
protected final void searchIterative(OperationResult opResult) throws SchemaException, ObjectNotFoundException, CommunicationException, ConfigurationException, SecurityViolationException, ExpressionEvaluationException
Description copied from class:AbstractSearchIterativeTaskPartExecution
Used to search using model or any similar higher-level interface. Defaults to search using repository.- Overrides:
searchIterative
in classAbstractSearchIterativeTaskPartExecution<O extends ObjectType,TH extends AbstractModelTaskHandler<TH,TE>,TE extends AbstractTaskExecution<TH,TE>,PE extends AbstractIterativeModelTaskPartExecution<O,TH,TE,PE,RH>,RH extends AbstractSearchIterativeItemProcessor<O,TH,TE,PE,RH>>
- Throws:
SchemaException
ObjectNotFoundException
CommunicationException
ConfigurationException
SecurityViolationException
ExpressionEvaluationException
-
modelProcessingAvailable
protected boolean modelProcessingAvailable()
- Overrides:
modelProcessingAvailable
in classAbstractSearchIterativeTaskPartExecution<O extends ObjectType,TH extends AbstractModelTaskHandler<TH,TE>,TE extends AbstractTaskExecution<TH,TE>,PE extends AbstractIterativeModelTaskPartExecution<O,TH,TE,PE,RH>,RH extends AbstractSearchIterativeItemProcessor<O,TH,TE,PE,RH>>
-
createShadowFetchingPreprocessor
@NotNull protected @NotNull ObjectPreprocessor<O> createShadowFetchingPreprocessor()
- Overrides:
createShadowFetchingPreprocessor
in classAbstractSearchIterativeTaskPartExecution<O extends ObjectType,TH extends AbstractModelTaskHandler<TH,TE>,TE extends AbstractTaskExecution<TH,TE>,PE extends AbstractIterativeModelTaskPartExecution<O,TH,TE,PE,RH>,RH extends AbstractSearchIterativeItemProcessor<O,TH,TE,PE,RH>>
-
checkRawAuthorization
protected void checkRawAuthorization(Task task, OperationResult result) throws CommunicationException, ObjectNotFoundException, SchemaException, SecurityViolationException, ConfigurationException, ExpressionEvaluationException
- Overrides:
checkRawAuthorization
in classAbstractSearchIterativeTaskPartExecution<O extends ObjectType,TH extends AbstractModelTaskHandler<TH,TE>,TE extends AbstractTaskExecution<TH,TE>,PE extends AbstractIterativeModelTaskPartExecution<O,TH,TE,PE,RH>,RH extends AbstractSearchIterativeItemProcessor<O,TH,TE,PE,RH>>
- Throws:
CommunicationException
ObjectNotFoundException
SchemaException
SecurityViolationException
ConfigurationException
ExpressionEvaluationException
-
-