Package org.apache.syncope.core.provisioning.java.job

Class ElasticsearchReindex

java.lang.Object

org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate<SchedTask>

org.apache.syncope.core.provisioning.java.job.ElasticsearchReindex

All Implemented Interfaces:

JobDelegate, SchedTaskJobDelegate

public class ElasticsearchReindex
extends AbstractSchedTaskJobDelegate<SchedTask>

Remove and rebuild all Elasticsearch indexes with information from existing users, groups and any objects.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	ElasticsearchReindex.ErrorLoggingBulkListener

Field Summary

Fields

Modifier and Type	Field	Description
protected AnyObjectDAO	anyObjectDAO
protected co.elastic.clients.elasticsearch.ElasticsearchClient	client
protected GroupDAO	groupDAO
protected ElasticsearchIndexManager	indexManager
protected RealmDAO	realmDAO
protected UserDAO	userDAO
protected ElasticsearchUtils	utils

Fields inherited from class org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate

auditManager, executor, LOG, manageOperationId, notificationManager, publisher, securityProperties, task, taskDAO, taskExecDAO, taskType, taskUtilsFactory

Constructor Summary

Constructors

Constructor	Description
ElasticsearchReindex()

Method Summary

Modifier and Type	Method	Description
protected co.elastic.clients.elasticsearch._types.mapping.TypeMapping	anyObjectMapping()
protected co.elastic.clients.elasticsearch.indices.IndexSettings	anyObjectSettings()
protected co.elastic.clients.elasticsearch._types.mapping.TypeMapping	auditMapping()
protected co.elastic.clients.elasticsearch.indices.IndexSettings	auditSettings()
protected String	doExecute(JobExecutionContext context)	The actual execution, delegated to child classes.
protected co.elastic.clients.elasticsearch._types.mapping.TypeMapping	groupMapping()
protected co.elastic.clients.elasticsearch.indices.IndexSettings	groupSettings()
protected boolean	hasToBeRegistered(TaskExec<?> execution)	Template method to determine whether this job's task execution has to be persisted or not.
protected co.elastic.clients.elasticsearch._types.mapping.TypeMapping	realmMapping()
protected co.elastic.clients.elasticsearch.indices.IndexSettings	realmSettings()
protected Pair<String,Long>	reindexAnyObjects(JobExecutionContext context)
protected String	reindexAudit(JobExecutionContext context)
protected Pair<String,Long>	reindexGroups(JobExecutionContext context)
protected Pair<String,Long>	reindexRealms(JobExecutionContext context)
protected Pair<String,Long>	reindexUsers(JobExecutionContext context)
protected co.elastic.clients.elasticsearch._types.mapping.TypeMapping	userMapping()
protected co.elastic.clients.elasticsearch.indices.IndexSettings	userSettings()

Methods inherited from class org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate

end, endExecution, execute, init, initExecution, register, setStatus

Methods inherited from class java.lang.Object

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

Field Details

client

@Autowired
protected co.elastic.clients.elasticsearch.ElasticsearchClient client

indexManager

@Autowired
protected ElasticsearchIndexManager indexManager

utils

@Autowired
protected ElasticsearchUtils utils

userDAO

@Autowired
protected UserDAO userDAO

groupDAO

@Autowired
protected GroupDAO groupDAO

anyObjectDAO

@Autowired
protected AnyObjectDAO anyObjectDAO

realmDAO

@Autowired
protected RealmDAO realmDAO

Constructor Details

ElasticsearchReindex

public ElasticsearchReindex()

Method Details

userSettings

protected co.elastic.clients.elasticsearch.indices.IndexSettings userSettings()

groupSettings

protected co.elastic.clients.elasticsearch.indices.IndexSettings groupSettings()

anyObjectSettings

protected co.elastic.clients.elasticsearch.indices.IndexSettings anyObjectSettings()

realmSettings

protected co.elastic.clients.elasticsearch.indices.IndexSettings realmSettings()

auditSettings

protected co.elastic.clients.elasticsearch.indices.IndexSettings auditSettings()

userMapping

protected co.elastic.clients.elasticsearch._types.mapping.TypeMapping userMapping()

groupMapping

protected co.elastic.clients.elasticsearch._types.mapping.TypeMapping groupMapping()

anyObjectMapping

protected co.elastic.clients.elasticsearch._types.mapping.TypeMapping anyObjectMapping()

realmMapping

protected co.elastic.clients.elasticsearch._types.mapping.TypeMapping realmMapping()

auditMapping

protected co.elastic.clients.elasticsearch._types.mapping.TypeMapping auditMapping()

reindexRealms

protected Pair<String,Long> reindexRealms(JobExecutionContext context)
                                   throws IOException

Throws:

IOException

reindexUsers

protected Pair<String,Long> reindexUsers(JobExecutionContext context)
                                  throws IOException

Throws:

IOException

reindexGroups

protected Pair<String,Long> reindexGroups(JobExecutionContext context)
                                   throws IOException

Throws:

IOException

reindexAnyObjects

protected Pair<String,Long> reindexAnyObjects(JobExecutionContext context)
                                       throws IOException

Throws:

IOException

reindexAudit

protected String reindexAudit(JobExecutionContext context)
                       throws IOException

Throws:

IOException

doExecute

protected String doExecute(JobExecutionContext context)
                    throws JobExecutionException

Description copied from class: AbstractSchedTaskJobDelegate

The actual execution, delegated to child classes.

Specified by:

doExecute in class AbstractSchedTaskJobDelegate<SchedTask>

Parameters:

context - job execution context, can be used to pass parameters to the job

Returns:

the task execution status to be set

Throws:

JobExecutionException - if anything goes wrong

hasToBeRegistered

protected boolean hasToBeRegistered(TaskExec<?> execution)

Description copied from class: AbstractSchedTaskJobDelegate

Template method to determine whether this job's task execution has to be persisted or not.

Overrides:

hasToBeRegistered in class AbstractSchedTaskJobDelegate<SchedTask>

Parameters:

execution - task execution

Returns:

whether to persist or not