ai.grakn.engine.task.postprocessing

Class PostProcessingTask

java.lang.Object

ai.grakn.engine.task.postprocessing.PostProcessingTask

All Implemented Interfaces:

BackgroundTask, AutoCloseable

public class PostProcessingTask
extends Object
implements BackgroundTask

Class which facilitates running PostProcessor jobs.

Author:

Filipe Peliz Pinto Teixeira

Constructor Summary

Constructors

Constructor and Description
PostProcessingTask(EngineGraknTxFactory factory, IndexPostProcessor indexPostProcessor, GraknConfig config)

Method Summary

Modifier and Type	Method and Description
void	close() Shutdown the task.
void	processIndex(ai.grakn.Keyspace keyspace, String index) Process the provided index belonging to the provided Keyspace.
void	run() The primary method to execute when the BackgroundTask starts executing

Methods inherited from class java.lang.Object

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

Methods inherited from interface ai.grakn.engine.task.BackgroundTask

period

Constructor Detail

PostProcessingTask

public PostProcessingTask(EngineGraknTxFactory factory,
                          IndexPostProcessor indexPostProcessor,
                          GraknConfig config)

Method Detail

run

public void run()

Description copied from interface: BackgroundTask

The primary method to execute when the BackgroundTask starts executing

Specified by:

run in interface BackgroundTask

processIndex

public void processIndex(ai.grakn.Keyspace keyspace,
                         String index)

Process the provided index belonging to the provided Keyspace. If post processing fails the index and ids relating to that index are restored back in the cache of RedisIndexStorage

Parameters:

keyspace - The Keyspace requiring post processing for a specific index

index - the index to be post processed

close

public void close()

Description copied from interface: BackgroundTask

Shutdown the task. This is useful if the task creates it's own processes

Specified by:

close in interface BackgroundTask

Specified by:

close in interface AutoCloseable