| Package | Description |
|---|---|
| ai.grakn.engine.loader |
Implements MutatorTask.
|
| ai.grakn.engine.postprocessing | |
| ai.grakn.engine.tasks | |
| ai.grakn.engine.tasks.manager | |
| ai.grakn.engine.tasks.manager.singlequeue | |
| ai.grakn.engine.tasks.mock |
| Modifier and Type | Method and Description |
|---|---|
boolean |
MutatorTask.start(java.util.function.Consumer<TaskCheckpoint> saveCheckpoint,
TaskConfiguration configuration,
TaskSubmitter taskSubmitter) |
| 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
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
TaskManager
The base TaskManager interface.
|
| Modifier and Type | Method and Description |
|---|---|
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.
|
| Modifier and Type | Class and Description |
|---|---|
class |
StandaloneTaskManager
In-memory task manager to schedule and execute tasks.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SingleQueueTaskManager
TaskManager implementation that operates using a single Kafka queue and controls the
lifecycle SingleQueueTaskManager |
| Modifier and Type | Method and Description |
|---|---|
boolean |
MockBackgroundTask.start(java.util.function.Consumer<TaskCheckpoint> saveCheckpoint,
TaskConfiguration configuration,
TaskSubmitter taskSubmitter) |
Copyright © 2017 Grakn Labs Ltd. All rights reserved.