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
Basic AI Task for cluster mapping.
- Since:
- 9.3
- See Also:
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected AIProcessingApiprotected static final Stringprotected Longprotected Stringprotected Exceptionprotected static final Stringstatic final intFields inherited from class overit.geocallapp.wfm.ai.bl.processing.task.BTBasicAIProcess
algorithmName, asyncQueueMode, configurationParamsHistory, elaborationHistory, factory, filesToDelete, headers, instanceType, modelName, resourcesFolder -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voidbuildDataAndUpdate(Date extractionDate, Long configuration, boolean generatedExperience, PoolKit poolKit) protected abstract FilebuildExperienceFile(Date extractionStartDate, Long configurationId, PoolKit poolKit) protected abstract FilebuildResourceFile(Date extractionDate, PoolKit pk) protected abstract FilebuildTeamFile(Date extractionStartDate, Long configurationId, PoolKit poolKit) protected voidcleanUselessExperiences(PoolKit poolKit) Delete all the experience records of the last configuration execution and those of current elaboration with data < yesterdayprotected voidelaborateTask(PoolKit poolKit) protected voidGeneric method that is usefull to recognize generic exceptions.protected abstract CalculateExperienceEventprotected DategetLastTrainingOrCMDate(PoolKit poolKit) Get the last training/cluster mapping execution date for the current configuration.protected intprotected DategetMostRecentDate(DBView configurationExecution) protected DategetMostRecentDateFromConfigurations(DBView confParams, PoolKit poolKit) prepareDataForClusterMapping(File experienceRecords, File resourceRecords, File teamRecords) updateClusterMapping(Map<String, String> presignedUrls) protected voidupdateExperience(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, writeLogTableMethods inherited from class overit.geocall.bl.BusinessTask
start, start, startAlone, startInBackground
-
Field Details
-
DATE_FIELD
- See Also:
-
SDF_DATE
- See Also:
-
occurredException
-
api
-
lastConfigurationExecuted
-
oc
-
WAITING_TIME
public static final int WAITING_TIME- See Also:
-
-
Constructor Details
-
BTBasicClusterMapping
public BTBasicClusterMapping()
-
-
Method Details
-
elaborateTask
- Specified by:
elaborateTaskin classBTBasicAIProcess- Throws:
DAExceptionDAValidateException
-
buildDataAndUpdate
protected void buildDataAndUpdate(Date extractionDate, Long configuration, boolean generatedExperience, PoolKit poolKit) throws DAException, DAValidateException - Throws:
DAExceptionDAValidateException
-
buildTeamFile
protected abstract File buildTeamFile(Date extractionStartDate, Long configurationId, PoolKit poolKit) throws DAException, DAValidateException - Throws:
DAExceptionDAValidateException
-
buildResourceFile
protected abstract File buildResourceFile(Date extractionDate, PoolKit pk) throws DAException, DAValidateException - Throws:
DAExceptionDAValidateException
-
buildExperienceFile
protected abstract File buildExperienceFile(Date extractionStartDate, Long configurationId, PoolKit poolKit) throws DAException, DAValidateException - Throws:
DAExceptionDAValidateException
-
getEventUpdateExperience
protected abstract CalculateExperienceEvent getEventUpdateExperience(CalculateExperienceEventInput input) throws DAValidateException, DAException - Throws:
DAValidateExceptionDAException
-
updateExperience
Method that calls the update experience in incremental mode.- Parameters:
startDate-pk-- Throws:
DAValidateExceptionDAException
-
evaluateException
Generic method that is usefull to recognize generic exceptions.- Throws:
DAExceptionDAValidateException
-
cleanUselessExperiences
Delete all the experience records of the last configuration execution and those of current elaboration with data < yesterday- Parameters:
poolKit-- Throws:
DAExceptionDAValidateException
-
getLastTrainingOrCMDate
Get the last training/cluster mapping execution date for the current configuration.- Parameters:
poolKit-- Returns:
- Throws:
DAExceptionDAValidateException
-
getMostRecentDateFromConfigurations
protected Date getMostRecentDateFromConfigurations(DBView confParams, PoolKit poolKit) throws DAException, DAValidateException - Throws:
DAExceptionDAValidateException
-
getMostRecentDate
-
getLogValidityDays
protected int getLogValidityDays()- Specified by:
getLogValidityDaysin classBTBasicAIProcess
-
updateClusterMapping
protected List<Map<String,Object>> updateClusterMapping(Map<String, String> presignedUrls) throws DAValidateException, DAException, InterruptedException, IOException -
prepareDataForClusterMapping
protected Map<String,String> prepareDataForClusterMapping(File experienceRecords, File resourceRecords, File teamRecords) throws IOException - Throws:
IOException
-