ai.grakn.engine.attribute.uniqueness.queue

Class RocksDbQueue

java.lang.Object

ai.grakn.engine.attribute.uniqueness.queue.RocksDbQueue

All Implemented Interfaces:

Queue

public class RocksDbQueue
extends Object
implements Queue

TODO

Author:

Ganeshwara Herawan Hananda

Constructor Summary

Constructors

Constructor and Description
RocksDbQueue()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RocksDbQueue

public RocksDbQueue()

Method Detail

insertAttribute

public void insertAttribute(Attribute attribute)

Description copied from interface: Queue

Enqueue a new attribute to the queue

Specified by:

insertAttribute in interface Queue

readAttributes

public Attributes readAttributes(int limit)
                          throws InterruptedException

Description copied from interface: Queue

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

Specified by:

readAttributes in interface Queue

Parameters:

limit - the maximum number of items to be returned.

Returns:

an Attributes instance containing a list of duplicates

Throws:

InterruptedException

ackAttributes

public void ackAttributes(Attributes attributes)

Specified by:

ackAttributes in interface Queue

close

public void close()