ai.grakn.engine.cache

Class EngineCacheDistributed

java.lang.Object

ai.grakn.engine.cache.EngineCacheDistributed

All Implemented Interfaces:

ai.grakn.graph.admin.ConceptCache

public class EngineCacheDistributed
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 rely on ConceptIds because the indexed lookup maybe faulty with vertices in need of post processing. This distributed version persists everything using ZookeeperConnection

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)
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)
static EngineCacheDistributed	init(ZookeeperConnection connection)

Methods inherited from class java.lang.Object

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

Method Detail

init

public static EngineCacheDistributed init(ZookeeperConnection connection)

getKeyspaces

public Set<String> getKeyspaces()

deleteJobCasting

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

deleteJobResource

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

getCastingJobs

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

getResourceJobs

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

addJobCasting

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

addJobResource

public void addJobResource(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)

getLastTimeJobAdded

public long getLastTimeJobAdded()

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