ai.grakn.engine.postprocessing

Class UpdatingInstanceCountTask

java.lang.Object

ai.grakn.engine.postprocessing.UpdatingInstanceCountTask

All Implemented Interfaces:

BackgroundTask

public class UpdatingInstanceCountTask
extends Object
implements BackgroundTask

Task that controls when types are updated with their new instance counts

This task begins only if enough time has passed (configurable) since the last time a job was added.

Author:

fppt

Field Summary

Fields

Modifier and Type	Field and Description
static GraknEngineConfig	CONFIG
static RedisConnection	redis

Constructor Summary

Constructors

Constructor and Description
UpdatingInstanceCountTask()

Method Summary

Modifier and Type	Method and Description
static TaskConfiguration	createConfig(String keyspace, String config) Helper method which creates the task config needed in order to execute the updating count task
static TaskState	createTask(Class creator) Helper method which creates PP Task States.
void	pause() Called to suspend the execution of a currently running task.
boolean	resume(java.util.function.Consumer<TaskCheckpoint> saveCheckpoint, TaskCheckpoint lastCheckpoint) This method may be called when resuming from a paused state or recovering from a crash or failure of any kind.
boolean	start(java.util.function.Consumer<TaskCheckpoint> saveCheckpoint, TaskConfiguration configuration, TaskSubmitter taskSubmitter) Called to start execution of the task, may be called on a newly scheduled or previously stopped task.
boolean	stop() Called to stop execution of the task, may be called on a running or paused task.

Methods inherited from class java.lang.Object

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

Field Detail

redis

public static final RedisConnection redis

CONFIG

public static final GraknEngineConfig CONFIG

Constructor Detail

UpdatingInstanceCountTask

public UpdatingInstanceCountTask()

Method Detail

start

public boolean start(java.util.function.Consumer<TaskCheckpoint> saveCheckpoint,
                     TaskConfiguration configuration,
                     TaskSubmitter taskSubmitter)

Description copied from interface: BackgroundTask

Called to start execution of the task, may be called on a newly scheduled or previously stopped task.

Specified by:

start in interface BackgroundTask

Parameters:

saveCheckpoint - Consumer which can be called at any time to save a state checkpoint that would allow the task to resume from this point should it crash.

configuration - The configuration needed to execute the task

taskSubmitter - Allows followup tasks to be submitted for processing

Returns:

true if the task successfully completed, or false if it was stopped.

stop

public boolean stop()

Description copied from interface: BackgroundTask

Called to stop execution of the task, may be called on a running or paused task. Task should stop gracefully.

Specified by:

stop in interface BackgroundTask

Returns:

true if the task was successfully stopped, or false if it could not be stopped. TODO: Should we allow start() to be called after stop()?

pause

public void pause()

Description copied from interface: BackgroundTask

Called to suspend the execution of a currently running task. The object may be destroyed after this call. TODO: stop running

Specified by:

pause in interface BackgroundTask

resume

public boolean resume(java.util.function.Consumer<TaskCheckpoint> saveCheckpoint,
                      TaskCheckpoint lastCheckpoint)

Description copied from interface: BackgroundTask

This method may be called when resuming from a paused state or recovering from a crash or failure of any kind.

Specified by:

resume in interface BackgroundTask

Parameters:

saveCheckpoint - Consumer which can be called at any time to save a state checkpoint that would allow the task to resume from this point should it crash.

lastCheckpoint - The last checkpoint as sent to saveCheckpoint.

createTask

public static TaskState createTask(Class creator)

Helper method which creates PP Task States.

Parameters:

creator - The class which is creating the task

Returns:

The executable postprocessing task state

createConfig

public static TaskConfiguration createConfig(String keyspace,
                                             String config)

Helper method which creates the task config needed in order to execute the updating count task

Parameters:

keyspace - The keyspace of the graph to execute this on.

config - The config which contains the concepts with updated counts

Returns:

The task configuration encapsulating the above details in a manner executable by the task runner