Uses of Class
ai.grakn.engine.tasks.TaskConfiguration

Packages that use TaskConfiguration

Package	Description
ai.grakn.engine.loader	Implements MutatorTask.
ai.grakn.engine.postprocessing
ai.grakn.engine.tasks
ai.grakn.engine.tasks.config
ai.grakn.engine.tasks.manager
ai.grakn.engine.tasks.manager.singlequeue
ai.grakn.engine.tasks.mock

Uses of TaskConfiguration in ai.grakn.engine.loader

Methods in ai.grakn.engine.loader with parameters of type TaskConfiguration

Modifier and Type	Method and Description
boolean	MutatorTask.start(java.util.function.Consumer<TaskCheckpoint> saveCheckpoint, TaskConfiguration configuration, TaskSubmitter taskSubmitter)

Uses of TaskConfiguration in ai.grakn.engine.postprocessing

Methods in ai.grakn.engine.postprocessing that return TaskConfiguration

Modifier and Type	Method and Description
static TaskConfiguration	UpdatingInstanceCountTask.createConfig(String keyspace, String config) Helper method which creates the task config needed in order to execute the updating count task
static TaskConfiguration	PostProcessingTask.createConfig(String keyspace, String config) Helper method which creates the task config needed in order to execute a PP task

Methods in ai.grakn.engine.postprocessing with parameters of type TaskConfiguration

Modifier and Type	Method and Description
boolean	UpdatingInstanceCountTask.start(java.util.function.Consumer<TaskCheckpoint> saveCheckpoint, TaskConfiguration configuration, TaskSubmitter taskSubmitter)
boolean	ResourceDeduplicationTask.start(java.util.function.Consumer<TaskCheckpoint> saveCheckpoint, TaskConfiguration configuration, TaskSubmitter taskSubmitter)
boolean	PostProcessingTask.start(java.util.function.Consumer<TaskCheckpoint> saveCheckpoint, TaskConfiguration configuration, TaskSubmitter taskSubmitter) Apply CASTING and RESOURCE post processing jobs the concept ids in the provided configuration

Uses of TaskConfiguration in ai.grakn.engine.tasks

Methods in ai.grakn.engine.tasks that return TaskConfiguration

Modifier and Type	Method and Description
TaskConfiguration	TaskConfigurationDeserializer.deserialize(String topic, byte[] data)
static TaskConfiguration	TaskConfiguration.of(mjson.Json checkpoint)

Methods in ai.grakn.engine.tasks with parameters of type TaskConfiguration

Modifier and Type	Method and Description
void	TaskSubmitter.addTask(TaskState taskState, TaskConfiguration configuration) Schedule a BackgroundTask for execution.
byte[]	TaskConfigurationSerializer.serialize(String topic, TaskConfiguration data)
boolean	BackgroundTask.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.

Uses of TaskConfiguration in ai.grakn.engine.tasks.config

Methods in ai.grakn.engine.tasks.config that return types with arguments of type TaskConfiguration

Modifier and Type	Method and Description
static org.apache.kafka.clients.consumer.Consumer<TaskState,TaskConfiguration>	ConfigHelper.kafkaConsumer(String groupId, Properties properties)
static org.apache.kafka.clients.producer.Producer<TaskState,TaskConfiguration>	ConfigHelper.kafkaProducer(Properties properties)

Uses of TaskConfiguration in ai.grakn.engine.tasks.manager

Methods in ai.grakn.engine.tasks.manager with parameters of type TaskConfiguration

Modifier and Type	Method and Description
void	StandaloneTaskManager.addTask(TaskState taskState, TaskConfiguration configuration)

Uses of TaskConfiguration in ai.grakn.engine.tasks.manager.singlequeue

Methods in ai.grakn.engine.tasks.manager.singlequeue with parameters of type TaskConfiguration

Modifier and Type	Method and Description
void	SingleQueueTaskManager.addTask(TaskState taskState, TaskConfiguration configuration) Serialize and send the given task to the given kafka queue

Constructor parameters in ai.grakn.engine.tasks.manager.singlequeue with type arguments of type TaskConfiguration

Constructor and Description
SingleQueueTaskRunner(SingleQueueTaskManager manager, EngineID engineID, ExternalOffsetStorage offsetStorage, int timeUntilBackoff, org.apache.kafka.clients.consumer.Consumer<TaskState,TaskConfiguration> consumer) Create a SingleQueueTaskRunner which retrieves tasks from the given and uses the given to store and retrieve information about tasks.

Uses of TaskConfiguration in ai.grakn.engine.tasks.mock

Methods in ai.grakn.engine.tasks.mock with parameters of type TaskConfiguration

Modifier and Type	Method and Description
boolean	MockBackgroundTask.start(java.util.function.Consumer<TaskCheckpoint> saveCheckpoint, TaskConfiguration configuration, TaskSubmitter taskSubmitter)