de.hybris.platform.solrfacetsearch.indexer.cron

Class SolrExtIndexerJob<T extends SolrExtIndexerCronJobModel>

java.lang.Object

de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable<T>

de.hybris.platform.solrfacetsearch.indexer.cron.SolrExtIndexerJob<T>

All Implemented Interfaces:

JobPerformable<T>

public class SolrExtIndexerJob<T extends SolrExtIndexerCronJobModel>
extends AbstractJobPerformable<T>

Job performable that triggers indexer operations. It allows you to have a separate query per SolrExtIndexerCronJobModel instance. It also allows you to perform partial updates.

Field Summary

Fields inherited from class de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable

flexibleSearchService, modelService, sessionService

Constructor Summary

Constructors

Constructor and Description
SolrExtIndexerJob()

Method Summary

Modifier and Type	Method and Description
protected java.util.Map<java.lang.String,java.lang.Object>	createQueryParameters(T cronJob, IndexConfig indexConfig, IndexedType indexedType)
protected BeanFactory	getBeanFactory()
FacetSearchConfigService	getFacetSearchConfigService()
IndexerQueriesExecutor	getIndexerQueriesExecutor()
IndexerService	getIndexerService()
PerformResult	perform(T cronJob) The execution body for a ServicelayerJob.
protected void	performIndexing(T cronJob, FacetSearchConfig facetSearchConfig, IndexedType indexedType, java.util.List<IndexedProperty> indexedProperties, java.util.List<PK> pks, java.util.Map<java.lang.String,java.lang.String> indexerHints)
protected java.util.List<IndexedProperty>	resolveIndexedProperties(T cronJob, IndexedType indexedType)
protected IndexedType	resolveIndexedType(T cronJob, IndexConfig indexConfig)
void	setBeanFactory(BeanFactory beanFactory)
void	setFacetSearchConfigService(FacetSearchConfigService facetSearchConfigService)
void	setIndexerQueriesExecutor(IndexerQueriesExecutor indexerQueriesExecutor)
void	setIndexerService(IndexerService indexerService)
protected void	validateCronJobParameters(T cronJob)

Methods inherited from class de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable

clearAbortRequestedIfNeeded, isAbortable, isPerformable, setFlexibleSearchService, setModelService, setSessionService

Methods inherited from class java.lang.Object

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

Constructor Detail

SolrExtIndexerJob

public SolrExtIndexerJob()

Method Detail

setFacetSearchConfigService

public void setFacetSearchConfigService(FacetSearchConfigService facetSearchConfigService)

getFacetSearchConfigService

public FacetSearchConfigService getFacetSearchConfigService()

setIndexerService

public void setIndexerService(IndexerService indexerService)

getIndexerService

public IndexerService getIndexerService()

setIndexerQueriesExecutor

public void setIndexerQueriesExecutor(IndexerQueriesExecutor indexerQueriesExecutor)

getIndexerQueriesExecutor

public IndexerQueriesExecutor getIndexerQueriesExecutor()

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)

getBeanFactory

protected BeanFactory getBeanFactory()

perform

public PerformResult perform(T cronJob)

Description copied from interface: JobPerformable

The execution body for a ServicelayerJob. Implement here your execution logic. It can be called synchronous or asynchronous. So be aware of thread-safety. Method will return a result object saying if the execution has reached end and if it was successful.

Specified by:

perform in interface JobPerformable<T extends SolrExtIndexerCronJobModel>

Specified by:

perform in class AbstractJobPerformable<T extends SolrExtIndexerCronJobModel>

Parameters:

cronJob - the related CronJob in whose context the execution will be performed.

Returns:

a PerformResult that indicates whether the execution was successfully executed or not and has finished or not.

validateCronJobParameters

protected void validateCronJobParameters(T cronJob)
                                  throws IndexerJobException

Throws:

IndexerJobException

resolveIndexedType

protected IndexedType resolveIndexedType(T cronJob,
                                         IndexConfig indexConfig)
                                  throws IndexerJobException

Throws:

IndexerJobException

resolveIndexedProperties

protected java.util.List<IndexedProperty> resolveIndexedProperties(T cronJob,
                                                                   IndexedType indexedType)
                                                            throws IndexerJobException

Throws:

IndexerJobException

createQueryParameters

protected java.util.Map<java.lang.String,java.lang.Object> createQueryParameters(T cronJob,
                                                                                 IndexConfig indexConfig,
                                                                                 IndexedType indexedType)
                                                                          throws IndexerJobException

Throws:

IndexerJobException

performIndexing

protected void performIndexing(T cronJob,
                               FacetSearchConfig facetSearchConfig,
                               IndexedType indexedType,
                               java.util.List<IndexedProperty> indexedProperties,
                               java.util.List<PK> pks,
                               java.util.Map<java.lang.String,java.lang.String> indexerHints)
                        throws IndexerJobException,
                               IndexerException

Throws:

IndexerJobException

IndexerException