ai.grakn.engine.task.postprocessing

Class RedisIndexStorage

java.lang.Object

ai.grakn.engine.task.postprocessing.RedisIndexStorage

public class RedisIndexStorage
extends Object

Stores a list of indices and vertex ids representing those indices which need to be post processed

Author:

fppt

Method Summary

Modifier and Type	Method and Description
void	addIndex(ai.grakn.Keyspace keyspace, String index, Set<ai.grakn.concept.ConceptId> conceptIds) Add an index to the list of indices which needs to be post processed
static RedisIndexStorage	create(redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool, com.codahale.metrics.MetricRegistry metricRegistry)
Set<ai.grakn.concept.ConceptId>	popIds(ai.grakn.Keyspace keyspace, String index) Gets and removes all the ids which we need to post process
String	popIndex(ai.grakn.Keyspace keyspace) Gets and removes the next index to post process

Methods inherited from class java.lang.Object

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

Method Detail

create

public static RedisIndexStorage create(redis.clients.util.Pool<redis.clients.jedis.Jedis> jedisPool,
                                       com.codahale.metrics.MetricRegistry metricRegistry)

addIndex

public void addIndex(ai.grakn.Keyspace keyspace,
                     String index,
                     Set<ai.grakn.concept.ConceptId> conceptIds)

Add an index to the list of indices which needs to be post processed

popIndex

@Nullable
public String popIndex(ai.grakn.Keyspace keyspace)

Gets and removes the next index to post process

popIds

public Set<ai.grakn.concept.ConceptId> popIds(ai.grakn.Keyspace keyspace,
                                              String index)

Gets and removes all the ids which we need to post process