ai.grakn.engine.attribute.uniqueness.queue

Class InMemoryQueue

java.lang.Object

ai.grakn.engine.attribute.uniqueness.queue.InMemoryQueue

All Implemented Interfaces:

Queue

public class InMemoryQueue
extends Object
implements Queue

TODO

Author:

Ganeshwara Herawan Hananda

Constructor Summary

Constructors

Constructor and Description
InMemoryQueue()

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 max) 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

InMemoryQueue

public InMemoryQueue()

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 max)

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:

max - the maximum number of items to be returned.

Returns:

an Attributes instance containing a list of duplicates

ackAttributes

public void ackAttributes(Attributes batch)

Specified by:

ackAttributes in interface Queue