Package org.gcube.vremanagement.executor.persistence.orientdb

Class OrientDBPersistenceConnector

java.lang.Object

org.gcube.vremanagement.executor.plugin.PluginStateNotification

org.gcube.vremanagement.executor.persistence.SmartExecutorPersistenceConnector

org.gcube.vremanagement.executor.persistence.orientdb.OrientDBPersistenceConnector

All Implemented Interfaces:

ScheduledTaskPersistence

public class OrientDBPersistenceConnector
extends SmartExecutorPersistenceConnector

Author:

Luca Frosini (ISTI - CNR)

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	CONTEXT
protected static final String	COUNT
protected static final String	ITERATION
protected com.orientechnologies.orient.core.db.ODatabasePool	oDatabasePool
protected static final String	PLUGIN_NAMES
protected static final String	PLUGIN_STATE
protected final String	RUN_ON
protected static final String	TIMESTAMP
protected static final String	UUID

Fields inherited from class org.gcube.vremanagement.executor.plugin.PluginStateNotification

inputs

Constructor Summary

Constructors

Constructor	Description
OrientDBPersistenceConnector(SmartExecutorPersistenceConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
void	addScheduledTask(ScheduledTask scheduledTask)	Create a Scheduled Task on persistence
void	close()	Close the connection to DB
Map<org.gcube.vremanagement.executor.plugin.PluginState,Long>	countFinalStates(Long since)	Counts the executions of the current Context that reached a final state, by that state: each execution of a Plugin records its final state once.
org.gcube.vremanagement.executor.plugin.PluginStateEvolution	getPluginInstanceState(UUID uuid, Integer iterationNumber)	Retrieve the status of the iterationNumber (passed as parameter) of a running/run Plugin which is/was identified by the UUID passed as parameter
ScheduledTask	getScheduledTask(UUID uuid)	Return the Scheduled Task if any, null otherwise
protected com.orientechnologies.orient.core.record.impl.ODocument	getScheduledTaskDocument(UUID uuid)
List<ScheduledTask>	getScheduledTasks(Collection<String> plugins)	Retrieve from the #SmartExecutorPersistenceConnector the orphaned Scheduled tasks
void	pluginStateEvolution(org.gcube.vremanagement.executor.plugin.PluginStateEvolution pluginStateEvolution, Exception exception)
protected void	prepareConnection(SmartExecutorPersistenceConfiguration configuration)
void	releaseScheduledTask(UUID uuid)	Release the Scheduled Task leaving it as orphan on persistence
void	releaseScheduledTask(ScheduledTask scheduledTask)	Release the Scheduled Task leaving it as orphan on persistence
void	removeScheduledTask(UUID uuid)	Remove from persistence the Scheduled Task.
void	removeScheduledTask(ScheduledTask scheduledTask)	Remove from persistence the Scheduled Task.
void	reserveScheduledTask(ScheduledTask scheduledTask)	Reserve an orphan Scheduled tasks
static void	shutdown()

Methods inherited from class java.lang.Object

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

Field Details

CONTEXT

protected static final String CONTEXT

See Also:

• Constant Field Values

UUID

protected static final String UUID

See Also:

• Constant Field Values

ITERATION

protected static final String ITERATION

See Also:

• Constant Field Values

TIMESTAMP

protected static final String TIMESTAMP

See Also:

• Constant Field Values

PLUGIN_STATE

protected static final String PLUGIN_STATE

See Also:

• Constant Field Values

COUNT

protected static final String COUNT

See Also:

• Constant Field Values

PLUGIN_NAMES

protected static final String PLUGIN_NAMES

See Also:

• Constant Field Values

RUN_ON

protected final String RUN_ON

See Also:

• Constant Field Values

oDatabasePool

protected com.orientechnologies.orient.core.db.ODatabasePool oDatabasePool

Constructor Details

OrientDBPersistenceConnector

public OrientDBPersistenceConnector(SmartExecutorPersistenceConfiguration configuration)
                             throws Exception

Throws:

Exception

Method Details

prepareConnection

protected void prepareConnection(SmartExecutorPersistenceConfiguration configuration)
                          throws Exception

Throws:

Exception

close

public void close()
           throws Exception

Description copied from class: SmartExecutorPersistenceConnector

Close the connection to DB

Specified by:

close in class SmartExecutorPersistenceConnector

Throws:

Exception - if fails

getPluginInstanceState

public org.gcube.vremanagement.executor.plugin.PluginStateEvolution getPluginInstanceState(UUID uuid,
 Integer iterationNumber)
                                                                                    throws org.gcube.vremanagement.executor.exception.PluginInstanceNotFoundException,
org.gcube.vremanagement.executor.exception.ExecutorException

Description copied from class: SmartExecutorPersistenceConnector

Retrieve the status of the iterationNumber (passed as parameter) of a running/run Plugin which is/was identified by the UUID passed as parameter

Specified by:

getPluginInstanceState in class SmartExecutorPersistenceConnector

Parameters:

uuid - the execution identifier of the running/run Plugin

iterationNumber - the iterationNumber (null to get the last)

Returns:

the actual/last PluginState of the Plugin

Throws:

org.gcube.vremanagement.executor.exception.PluginInstanceNotFoundException - if the plugin instance is not found

org.gcube.vremanagement.executor.exception.ExecutorException - if the operation fails

pluginStateEvolution

public void pluginStateEvolution(org.gcube.vremanagement.executor.plugin.PluginStateEvolution pluginStateEvolution,
 Exception exception)
                          throws Exception

Specified by:

pluginStateEvolution in class org.gcube.vremanagement.executor.plugin.PluginStateNotification

Throws:

Exception

countFinalStates

public Map<org.gcube.vremanagement.executor.plugin.PluginState,Long> countFinalStates(Long since)
                                                                               throws org.gcube.vremanagement.executor.exception.ExecutorException

Description copied from class: SmartExecutorPersistenceConnector

Counts the executions of the current Context that reached a final state, by that state: each execution of a Plugin records its final state once.

Specified by:

countFinalStates in class SmartExecutorPersistenceConnector

Parameters:

since - only the executions that reached their final state at this time or later, in milliseconds since the epoch; null counts all the executions in the database

Returns:

the number of executions by final state, with every final state present

Throws:

org.gcube.vremanagement.executor.exception.ExecutorException - if the operation fails

addScheduledTask

public void addScheduledTask(ScheduledTask scheduledTask)
                      throws SchedulePersistenceException

Description copied from interface: ScheduledTaskPersistence

Create a Scheduled Task on persistence

Parameters:

scheduledTask - to create on persistence

Throws:

SchedulePersistenceException - if fails

getScheduledTasks

public List<ScheduledTask> getScheduledTasks(Collection<String> plugins)
                                      throws SchedulePersistenceException

Description copied from interface: ScheduledTaskPersistence

Retrieve from the #SmartExecutorPersistenceConnector the orphaned Scheduled tasks

Returns:

the list of orphaned Scheduled

Throws:

SchedulePersistenceException - if fails

getScheduledTaskDocument

protected com.orientechnologies.orient.core.record.impl.ODocument getScheduledTaskDocument(UUID uuid)
                                                                                    throws SchedulePersistenceException

Throws:

SchedulePersistenceException

getScheduledTask

public ScheduledTask getScheduledTask(UUID uuid)
                               throws SchedulePersistenceException

Description copied from interface: ScheduledTaskPersistence

Return the Scheduled Task if any, null otherwise

Parameters:

uuid - which identify the Scheduled Task

Returns:

LaunchParameter of the Scheduled task if any, null otherwise

Throws:

SchedulePersistenceException - if fails

reserveScheduledTask

public void reserveScheduledTask(ScheduledTask scheduledTask)
                          throws SchedulePersistenceException

Description copied from interface: ScheduledTaskPersistence

Reserve an orphan Scheduled tasks

Throws:

SchedulePersistenceException - if fails

removeScheduledTask

public void removeScheduledTask(UUID uuid)
                         throws SchedulePersistenceException

Description copied from interface: ScheduledTaskPersistence

Remove from persistence the Scheduled Task.

Parameters:

uuid - the uuid which (will) identify the task on the SmartExecutor instance

Throws:

SchedulePersistenceException

removeScheduledTask

public void removeScheduledTask(ScheduledTask scheduledTask)
                         throws SchedulePersistenceException

Description copied from interface: ScheduledTaskPersistence

Remove from persistence the Scheduled Task.

Throws:

SchedulePersistenceException

releaseScheduledTask

public void releaseScheduledTask(UUID uuid)
                          throws SchedulePersistenceException

Description copied from interface: ScheduledTaskPersistence

Release the Scheduled Task leaving it as orphan on persistence

Parameters:

uuid - the uuid which (will) identify the task on the SmartExecutor instance

Throws:

SchedulePersistenceException

releaseScheduledTask

public void releaseScheduledTask(ScheduledTask scheduledTask)
                          throws SchedulePersistenceException

Description copied from interface: ScheduledTaskPersistence

Release the Scheduled Task leaving it as orphan on persistence

Throws:

SchedulePersistenceException

shutdown

public static void shutdown()