ai.grakn.engine.cache

Class EngineCacheStandAlone

java.lang.Object

ai.grakn.engine.cache.EngineCacheStandAlone

All Implemented Interfaces:

ai.grakn.graph.admin.ConceptCache

public class EngineCacheStandAlone
extends Object

Engine's internal Concept ID cache

This is a cache which houses Vertex ids. It keeps these ids so that we can lookup the vertices in need of postprocessing directly. We cannot relay on ConceptIds because the indexed lookup maybe faulty with vertices in need of post processing. This stand alone version keeps everything in memory when running a single engine.

Author:

fppt

Method Summary

Modifier and Type	Method and Description
void	addJobCasting(String keyspace, String castingIndex, ai.grakn.concept.ConceptId castingId)
void	addJobInstanceCount(String keyspace, ai.grakn.concept.TypeLabel name, long instanceCount)
void	addJobResource(String keyspace, String resourceIndex, ai.grakn.concept.ConceptId resourceId)
void	clearAllJobs(String keyspace)
void	clearJobSetCastings(String keyspace, String conceptIndex)
void	clearJobSetResources(String keyspace, String conceptIndex)
void	deleteJobCasting(String keyspace, String castingIndex, ai.grakn.concept.ConceptId castingId)
void	deleteJobInstanceCount(String keyspace, ai.grakn.concept.TypeLabel name)
void	deleteJobResource(String keyspace, String resourceIndex, ai.grakn.concept.ConceptId resourceId)
static EngineCacheStandAlone	getCache()
Map<String,Set<ai.grakn.concept.ConceptId>>	getCastingJobs(String keyspace)
Map<ai.grakn.concept.TypeLabel,Long>	getInstanceCountJobs(String keyspace)
Set<String>	getKeyspaces()
long	getLastTimeJobAdded()
long	getNumCastingJobs(String keyspace)
long	getNumJobs(String keyspace)
long	getNumResourceJobs(String keyspace)
Map<String,Set<ai.grakn.concept.ConceptId>>	getResourceJobs(String keyspace)

Methods inherited from class java.lang.Object

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

Method Detail

getCache

public static EngineCacheStandAlone getCache()

getKeyspaces

public Set<String> getKeyspaces()

getLastTimeJobAdded

public long getLastTimeJobAdded()

getCastingJobs

public Map<String,Set<ai.grakn.concept.ConceptId>> getCastingJobs(String keyspace)

addJobCasting

public void addJobCasting(String keyspace,
                          String castingIndex,
                          ai.grakn.concept.ConceptId castingId)

deleteJobCasting

public void deleteJobCasting(String keyspace,
                             String castingIndex,
                             ai.grakn.concept.ConceptId castingId)

getResourceJobs

public Map<String,Set<ai.grakn.concept.ConceptId>> getResourceJobs(String keyspace)

addJobResource

public void addJobResource(String keyspace,
                           String resourceIndex,
                           ai.grakn.concept.ConceptId resourceId)

deleteJobResource

public void deleteJobResource(String keyspace,
                              String resourceIndex,
                              ai.grakn.concept.ConceptId resourceId)

clearJobSetResources

public void clearJobSetResources(String keyspace,
                                 String conceptIndex)

clearJobSetCastings

public void clearJobSetCastings(String keyspace,
                                String conceptIndex)

clearAllJobs

public void clearAllJobs(String keyspace)

getInstanceCountJobs

public Map<ai.grakn.concept.TypeLabel,Long> getInstanceCountJobs(String keyspace)

addJobInstanceCount

public void addJobInstanceCount(String keyspace,
                                ai.grakn.concept.TypeLabel name,
                                long instanceCount)

deleteJobInstanceCount

public void deleteJobInstanceCount(String keyspace,
                                   ai.grakn.concept.TypeLabel name)

getNumJobs

public long getNumJobs(String keyspace)

Specified by:

getNumJobs in interface ai.grakn.graph.admin.ConceptCache

getNumCastingJobs

public long getNumCastingJobs(String keyspace)

Specified by:

getNumCastingJobs in interface ai.grakn.graph.admin.ConceptCache

getNumResourceJobs

public long getNumResourceJobs(String keyspace)

Specified by:

getNumResourceJobs in interface ai.grakn.graph.admin.ConceptCache