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:
SchedTaskJobDelegate
public class ElasticsearchReindex extends AbstractSchedTaskJobDelegate<SchedTask>
Remove and rebuild all Elasticsearch indexes with information from existing users, groups and any objects.

  • Field Details

  • 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()

    • 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