ai.grakn.engine.attribute.uniqueness.queue

Interface Queue

All Known Implementing Classes:

InMemoryQueue, RocksDbQueue

public interface Queue

TODO

Author:

Ganeshwara Herawan Hananda

Method Summary

Modifier and Type	Method and Description
void	ackAttributes(Attributes batch)
void	insertAttribute(Attribute attribute) Enqueue a new attribute to the queue
Attributes	readAttributes(int limit) get n attributes where min <= n < limit.

Method Detail

insertAttribute

void insertAttribute(Attribute attribute)

Enqueue a new attribute to the queue

Parameters:

attribute -

readAttributes

Attributes readAttributes(int limit)
                   throws InterruptedException

get n attributes where min <= n < limit. For fault tolerance, attributes are not deleted from the queue until Attributes::markProcessed() is called.

Parameters:

limit - the maximum number of items to be returned.

Returns:

an Attributes instance containing a list of duplicates

Throws:

InterruptedException

ackAttributes

void ackAttributes(Attributes batch)