Package overit.geocallapp.wfm.ai.bl.processing.task

Class BTBasicClusterMapping

java.lang.Object

overit.geocall.bl.BusinessTask<Void>

overit.geocallapp.wfm.ai.bl.processing.task.BTBasicAIProcess

overit.geocallapp.wfm.ai.bl.processing.task.BTBasicClusterMapping

All Implemented Interfaces:

Serializable, Tool

Direct Known Subclasses:

BTClusterMappingAgendaAffinity, BTClusterMappingTeamSuggestion

public abstract class BTBasicClusterMapping
extends BTBasicAIProcess

Basic AI Task for cluster mapping.

Since:

9.3

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected AIProcessingApi	api
protected static final String	DATE_FIELD
protected Long	lastConfigurationExecuted
protected String	oc
protected Exception	occurredException
protected static final String	SDF_DATE
static final int	WAITING_TIME

Fields inherited from class overit.geocallapp.wfm.ai.bl.processing.task.BTBasicAIProcess

algorithmName, asyncQueueMode, configurationParamsHistory, elaborationHistory, factory, filesToDelete, headers, instanceType, modelName, resourcesFolder

Constructor Summary

Constructors

Constructor	Description
BTBasicClusterMapping()

Method Summary

Modifier and Type	Method	Description
protected void	buildDataAndUpdate(Date extractionDate, Long configuration, boolean generatedExperience, PoolKit poolKit)
protected abstract File	buildExperienceFile(Date extractionStartDate, Long configurationId, PoolKit poolKit)
protected abstract File	buildResourceFile(Date extractionDate, PoolKit pk)
protected abstract File	buildTeamFile(Date extractionStartDate, Long configurationId, PoolKit poolKit)
protected void	cleanUselessExperiences(PoolKit poolKit)	Delete all the experience records of the last configuration execution and those of current elaboration with data < yesterday
protected void	elaborateTask(PoolKit poolKit)
protected void	evaluateException()	Generic method that is usefull to recognize generic exceptions.
protected abstract CalculateExperienceEvent	getEventUpdateExperience(CalculateExperienceEventInput input)
protected Date	getLastTrainingOrCMDate(PoolKit poolKit)	Get the last training/cluster mapping execution date for the current configuration.
protected int	getLogValidityDays()
protected Date	getMostRecentDate(DBView configurationExecution)
protected Date	getMostRecentDateFromConfigurations(DBView confParams, PoolKit poolKit)
protected Map<String,String>	prepareDataForClusterMapping(File experienceRecords, File resourceRecords, File teamRecords)
protected List<Map<String,Object>>	updateClusterMapping(Map<String,String> presignedUrls)
protected void	updateExperience(Date startDate, PoolKit pk)	Method that calls the update experience in incremental mode.

Methods inherited from class overit.geocallapp.wfm.ai.bl.processing.task.BTBasicAIProcess

body, buildHeaders, checkConfiguration, clearOldLogs, deleteFileS3, deleteTemporaryFiles, getAiConfiguration, getAwsUploadPath, getConfigurationParamsHistory, getElaborationHistory, getError, getJobName, getResourcesFolder, getTrainingType, isAsyncQueueMode, prepareDataForApi, setAiConfiguration, setAsyncQueueMode, setJobName, setResourcesFolder, setTrainingType, uploadFileS3, writeLogTable

Methods inherited from class overit.geocall.bl.BusinessTask

start, start, startAlone, startInBackground

Methods inherited from class java.lang.Object

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

Field Details

DATE_FIELD

protected static final String DATE_FIELD

See Also:

• Constant Field Values

SDF_DATE

protected static final String SDF_DATE

See Also:

• Constant Field Values

occurredException

protected Exception occurredException

api

protected AIProcessingApi api

lastConfigurationExecuted

protected Long lastConfigurationExecuted

oc

protected String oc

WAITING_TIME

public static final int WAITING_TIME

See Also:

• Constant Field Values

Constructor Details

BTBasicClusterMapping

public BTBasicClusterMapping()

Method Details

elaborateTask

protected void elaborateTask(PoolKit poolKit)
                      throws DAException,
DAValidateException

Specified by:

elaborateTask in class BTBasicAIProcess

Throws:

DAException

DAValidateException

buildDataAndUpdate

protected void buildDataAndUpdate(Date extractionDate,
 Long configuration,
 boolean generatedExperience,
 PoolKit poolKit)
                           throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

buildTeamFile

protected abstract File buildTeamFile(Date extractionStartDate,
 Long configurationId,
 PoolKit poolKit)
                               throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

buildResourceFile

protected abstract File buildResourceFile(Date extractionDate,
 PoolKit pk)
                                   throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

buildExperienceFile

protected abstract File buildExperienceFile(Date extractionStartDate,
 Long configurationId,
 PoolKit poolKit)
                                     throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

getEventUpdateExperience

protected abstract CalculateExperienceEvent getEventUpdateExperience(CalculateExperienceEventInput input)
                                                              throws DAValidateException,
DAException

Throws:

DAValidateException

DAException

updateExperience

protected void updateExperience(Date startDate,
 PoolKit pk)
                         throws DAValidateException,
DAException

Method that calls the update experience in incremental mode.

Parameters:

startDate -

pk -

Throws:

DAValidateException

DAException

evaluateException

protected void evaluateException()
                          throws DAException,
DAValidateException

Generic method that is usefull to recognize generic exceptions.

Throws:

DAException

DAValidateException

cleanUselessExperiences

protected void cleanUselessExperiences(PoolKit poolKit)
                                throws DAException,
DAValidateException

Delete all the experience records of the last configuration execution and those of current elaboration with data < yesterday

Parameters:

poolKit -

Throws:

DAException

DAValidateException

getLastTrainingOrCMDate

protected Date getLastTrainingOrCMDate(PoolKit poolKit)
                                throws DAException,
DAValidateException

Get the last training/cluster mapping execution date for the current configuration.

Parameters:

poolKit -

Returns:

Throws:

DAException

DAValidateException

getMostRecentDateFromConfigurations

protected Date getMostRecentDateFromConfigurations(DBView confParams,
 PoolKit poolKit)
                                            throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

getMostRecentDate

protected Date getMostRecentDate(DBView configurationExecution)

getLogValidityDays

protected int getLogValidityDays()

Specified by:

getLogValidityDays in class BTBasicAIProcess

updateClusterMapping

protected List<Map<String,Object>> updateClusterMapping(Map<String,String> presignedUrls)
                                                 throws DAValidateException,
DAException,
InterruptedException,
IOException

Throws:

DAValidateException

DAException

InterruptedException

IOException

prepareDataForClusterMapping

protected Map<String,String> prepareDataForClusterMapping(File experienceRecords,
 File resourceRecords,
 File teamRecords)
                                                   throws IOException

Throws:

IOException