| Package | Description |
|---|---|
| ai.grakn.engine.attribute.deduplicator.queue |
| Modifier and Type | Method and Description |
|---|---|
static Attribute |
Attribute.create(ai.grakn.Keyspace keyspace,
String index,
ai.grakn.concept.ConceptId conceptId) |
| Modifier and Type | Method and Description |
|---|---|
List<Attribute> |
RocksDbQueue.read(int limit)
Read at most N attributes from the beginning of the queue.
|
| Modifier and Type | Method and Description |
|---|---|
void |
RocksDbQueue.insert(Attribute attribute)
insert a new attribute at the end of the queue.
|
| Modifier and Type | Method and Description |
|---|---|
void |
RocksDbQueue.ack(List<Attribute> attributes)
Remove attributes from the queue.
|
Copyright © 2018 Grakn Labs Ltd. All rights reserved.