ai.grakn.engine.attribute.uniqueness

Class AttributeUniqueness

java.lang.Object

ai.grakn.engine.attribute.uniqueness.AttributeUniqueness

public class AttributeUniqueness
extends Object

This class is responsible for merging attribute duplicates which is done in order to maintain attribute uniqueness. It is an always-on background thread which continuously merge duplicates. This means that eventually, every attribute instance will have a unique value, as the duplicates will have been removed. A new incoming attribute will immediately trigger the merge operation, meaning that duplicates are merged in almost real-time speed. It is fault-tolerant and will re-process incoming attributes if Grakn crashes during a merge process.

Author:

Ganeshwara Herawan Hananda

Field Summary

Fields

Modifier and Type	Field and Description
static int	QUEUE_GET_BATCH_MAX
static AttributeUniqueness	singleton

Constructor Summary

Constructors

Constructor and Description
AttributeUniqueness()

Method Summary

Modifier and Type	Method and Description
void	insertAttribute(ai.grakn.Keyspace keyspace, String value, ai.grakn.concept.ConceptId conceptId)
void	mergeNow(int max)
void	stopDaemon() Stops the attribute merger daemon

Methods inherited from class java.lang.Object

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

Field Detail

singleton

public static AttributeUniqueness singleton

QUEUE_GET_BATCH_MAX

public static final int QUEUE_GET_BATCH_MAX

See Also:

Constant Field Values

Constructor Detail

AttributeUniqueness

public AttributeUniqueness()

Method Detail

insertAttribute

public void insertAttribute(ai.grakn.Keyspace keyspace,
                            String value,
                            ai.grakn.concept.ConceptId conceptId)

mergeNow

public void mergeNow(int max)

stopDaemon

public void stopDaemon()

Stops the attribute merger daemon