| Package | Description |
|---|---|
| ai.grakn.engine.tasks.manager | |
| ai.grakn.engine.tasks.manager.singlequeue |
| Modifier and Type | Method and Description |
|---|---|
static ExternalStorageRebalancer |
ExternalStorageRebalancer.rebalanceListener(org.apache.kafka.clients.consumer.Consumer consumer,
ExternalOffsetStorage externalOffsetStorage) |
| 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.