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

Class ElasticsearchReindex

java.lang.Object

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

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

All Implemented Interfaces:

JobDelegate, SchedTaskJobDelegate

public class ElasticsearchReindex
extends AbstractSchedTaskJobDelegate

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

Field Summary

Fields

Modifier and Type	Field and Description
protected AnyObjectDAO	anyObjectDAO
protected org.elasticsearch.client.RestHighLevelClient	client
protected GroupDAO	groupDAO
protected ElasticsearchIndexManager	indexManager
protected UserDAO	userDAO
protected ElasticsearchUtils	utils

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

auditManager, entityFactory, interrupt, interrupted, LOG, notificationManager, publisher, task, taskDAO, taskDataBinder, taskExecDAO

Constructor Summary

Constructors

Constructor and Description
ElasticsearchReindex()

Method Summary

Modifier and Type	Method and Description
protected org.elasticsearch.xcontent.XContentBuilder	anyObjectMapping()
protected org.elasticsearch.xcontent.XContentBuilder	anyObjectSettings()
protected org.elasticsearch.xcontent.XContentBuilder	auditMapping()
protected org.elasticsearch.xcontent.XContentBuilder	auditSettings()
protected String	doExecute(boolean dryRun, org.quartz.JobExecutionContext context) The actual execution, delegated to child classes.
protected org.elasticsearch.xcontent.XContentBuilder	groupMapping()
protected org.elasticsearch.xcontent.XContentBuilder	groupSettings()
protected boolean	hasToBeRegistered(TaskExec execution) Template method to determine whether this job's task execution has to be persisted or not.
protected org.elasticsearch.xcontent.XContentBuilder	userMapping()
protected org.elasticsearch.xcontent.XContentBuilder	userSettings()

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

execute, interrupt, isInterrupted, register, setStatus

Methods inherited from class java.lang.Object

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

Field Detail

client

@Autowired
protected org.elasticsearch.client.RestHighLevelClient 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

Constructor Detail

ElasticsearchReindex

public ElasticsearchReindex()

Method Detail

userSettings

protected org.elasticsearch.xcontent.XContentBuilder userSettings()
                                                           throws IOException

Throws:

IOException

groupSettings

protected org.elasticsearch.xcontent.XContentBuilder groupSettings()
                                                            throws IOException

Throws:

IOException

anyObjectSettings

protected org.elasticsearch.xcontent.XContentBuilder anyObjectSettings()
                                                                throws IOException

Throws:

IOException

auditSettings

protected org.elasticsearch.xcontent.XContentBuilder auditSettings()
                                                            throws IOException

Throws:

IOException

userMapping

protected org.elasticsearch.xcontent.XContentBuilder userMapping()
                                                          throws IOException

Throws:

IOException

groupMapping

protected org.elasticsearch.xcontent.XContentBuilder groupMapping()
                                                           throws IOException

Throws:

IOException

anyObjectMapping

protected org.elasticsearch.xcontent.XContentBuilder anyObjectMapping()
                                                               throws IOException

Throws:

IOException

auditMapping

protected org.elasticsearch.xcontent.XContentBuilder auditMapping()
                                                           throws IOException

Throws:

IOException

doExecute

protected String doExecute(boolean dryRun,
                           org.quartz.JobExecutionContext context)
                    throws org.quartz.JobExecutionException

Description copied from class: AbstractSchedTaskJobDelegate

The actual execution, delegated to child classes.

Specified by:

doExecute in class AbstractSchedTaskJobDelegate

Parameters:

dryRun - whether to actually touch the data

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

Returns:

the task execution status to be set

Throws:

org.quartz.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

Parameters:

execution - task execution

Returns:

wether to persist or not