| Package | Description |
|---|---|
| ai.grakn.engine.postprocessing | |
| ai.grakn.engine.tasks | |
| ai.grakn.engine.tasks.config | |
| ai.grakn.engine.tasks.manager | |
| ai.grakn.engine.tasks.manager.singlequeue |
| 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
|
| Modifier and Type | Method and Description |
|---|---|
TaskConfiguration |
BackgroundTask.configuration()
Get the configuration needed to execute the task
|
TaskConfiguration |
TaskConfigurationDeserializer.deserialize(String topic,
byte[] data) |
static TaskConfiguration |
TaskConfiguration.of(mjson.Json checkpoint) |
| Modifier and Type | Method and Description |
|---|---|
void |
TaskSubmitter.addTask(TaskState taskState,
TaskConfiguration configuration)
Schedule a
BackgroundTask for execution. |
void |
BackgroundTask.addTask(TaskState taskState,
TaskConfiguration configuration)
Submit a new task for execution
|
void |
BackgroundTask.initialize(java.util.function.Consumer<TaskCheckpoint> saveCheckpoint,
TaskConfiguration configuration,
TaskSubmitter taskSubmitter,
GraknEngineConfig engineConfig,
RedisConnection redis,
EngineGraknGraphFactory factory)
Initialize the
BackgroundTask. |
byte[] |
TaskConfigurationSerializer.serialize(String topic,
TaskConfiguration data) |
| 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) |
| Modifier and Type | Method and Description |
|---|---|
void |
StandaloneTaskManager.addTask(TaskState taskState,
TaskConfiguration configuration) |
| 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 and Description |
|---|
SingleQueueTaskRunner(SingleQueueTaskManager manager,
EngineID engineID,
GraknEngineConfig config,
RedisConnection redis,
EngineGraknGraphFactory factory,
ExternalOffsetStorage offsetStorage,
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. |
Copyright © 2017 Grakn Labs Ltd. All rights reserved.