ai.grakn.graph.internal

Class AbstractGraknGraph<G extends org.apache.tinkerpop.gremlin.structure.Graph>

java.lang.Object

ai.grakn.graph.internal.AbstractGraknGraph<G>

Type Parameters:

G - A vendor specific implementation of a Tinkerpop Graph.

All Implemented Interfaces:

GraknAdmin, GraknGraph, AutoCloseable

Direct Known Subclasses:

GraknTinkerGraph

public abstract class AbstractGraknGraph<G extends org.apache.tinkerpop.gremlin.structure.Graph>
extends Object
implements GraknGraph, GraknAdmin

The Grakn Graph Base Implementation

This defines how a grakn graph sits on top of a Tinkerpop Graph. It mostly act as a construction object which ensure the resulting graph conforms to the Grakn Object model.

Author:

fppt

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
AbstractGraknGraph(G graph, String keyspace, String engine, boolean batchLoadingEnabled)

Method Summary

Modifier and Type	Method and Description
GraknAdmin	admin()
<T extends Concept> T	buildConcept(org.apache.tinkerpop.gremlin.structure.Vertex vertex)
void	clear() Clears the graph completely.
protected void	clearGraph()
void	close() Closes the current graph, rendering it unusable.
void	closeGraph(String closedReason)
void	closePermanent()
void	commit() Commits the graph
void	commit(boolean submitLogs)
protected void	commitTx()
void	finaliseClose(Runnable closer, String closedReason)
boolean	fixDuplicateCasting(Object castingId) Merges duplicate castings if one is found.
boolean	fixDuplicateResources(Set<Object> resourceIds)
<T extends Concept> T	getConcept(Schema.ConceptProperty key, String value)
<T extends Concept> T	getConcept(String id)
<T extends Concept> T	getConceptByBaseIdentifier(Object baseIdentifier)
ConceptLog	getConceptLog()
Set<ai.grakn.graph.internal.ConceptImpl>	getConcepts(Schema.ConceptProperty key, Object value)
ai.grakn.graph.internal.ElementFactory	getElementFactory()
EntityType	getEntityType(String name)
String	getKeyspace()
Type	getMetaConcept()
EntityType	getMetaEntityType()
RelationType	getMetaRelationType()
ResourceType	getMetaResourceType()
RoleType	getMetaRoleType()
RuleType	getMetaRuleConstraint()
RuleType	getMetaRuleInference()
RuleType	getMetaRuleType()
Relation	getRelation(RelationType relationType, Map<RoleType,Instance> roleMap)
RelationType	getRelationType(String name)
<V> Collection<Resource<V>>	getResourcesByValue(V value)
<V> ResourceType<V>	getResourceType(String name)
RoleType	getRoleType(String name)
RuleType	getRuleType(String name)
G	getTinkerPopGraph()
org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversal<org.apache.tinkerpop.gremlin.structure.Vertex,org.apache.tinkerpop.gremlin.structure.Vertex>	getTinkerTraversal()
Type	getType(String name)
QueryBuilder	graql()
boolean	hasCommitted()
boolean	implicitConceptsVisible()
boolean	initialiseMetaConcepts()
boolean	isBatchLoadingEnabled()
boolean	isClosed()
EntityType	putEntityType(String name)
RelationType	putRelationType(String name)
<V> ResourceType<V>	putResourceType(String name, ResourceType.DataType<V> dataType)
<V> ResourceType<V>	putResourceTypeUnique(String name, ResourceType.DataType<V> dataType)
RoleType	putRoleType(String name)
RuleType	putRuleType(String name)
void	rollback()
void	showImplicitConcepts(boolean flag)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected final org.slf4j.Logger LOG

Constructor Detail

AbstractGraknGraph

public AbstractGraknGraph(G graph,
                          String keyspace,
                          String engine,
                          boolean batchLoadingEnabled)

Method Detail

getKeyspace

public String getKeyspace()

Specified by:

getKeyspace in interface GraknGraph

isClosed

public boolean isClosed()

Specified by:

isClosed in interface GraknGraph

implicitConceptsVisible

public boolean implicitConceptsVisible()

Specified by:

implicitConceptsVisible in interface GraknGraph

showImplicitConcepts

public void showImplicitConcepts(boolean flag)

Specified by:

showImplicitConcepts in interface GraknGraph

admin

public GraknAdmin admin()

Specified by:

admin in interface GraknGraph

buildConcept

public <T extends Concept> T buildConcept(org.apache.tinkerpop.gremlin.structure.Vertex vertex)

Specified by:

buildConcept in interface GraknAdmin

hasCommitted

public boolean hasCommitted()

isBatchLoadingEnabled

public boolean isBatchLoadingEnabled()

initialiseMetaConcepts

public boolean initialiseMetaConcepts()

getTinkerPopGraph

public G getTinkerPopGraph()

getTinkerTraversal

public org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversal<org.apache.tinkerpop.gremlin.structure.Vertex,org.apache.tinkerpop.gremlin.structure.Vertex> getTinkerTraversal()

Specified by:

getTinkerTraversal in interface GraknAdmin

graql

public QueryBuilder graql()

Specified by:

graql in interface GraknGraph

getElementFactory

public ai.grakn.graph.internal.ElementFactory getElementFactory()

getConcept

public <T extends Concept> T getConcept(Schema.ConceptProperty key,
                                        String value)

getConcepts

public Set<ai.grakn.graph.internal.ConceptImpl> getConcepts(Schema.ConceptProperty key,
                                                            Object value)

getConceptLog

public ConceptLog getConceptLog()

putEntityType

public EntityType putEntityType(String name)

Specified by:

putEntityType in interface GraknGraph

putRelationType

public RelationType putRelationType(String name)

Specified by:

putRelationType in interface GraknGraph

putRoleType

public RoleType putRoleType(String name)

Specified by:

putRoleType in interface GraknGraph

putResourceType

public <V> ResourceType<V> putResourceType(String name,
                                           ResourceType.DataType<V> dataType)

Specified by:

putResourceType in interface GraknGraph

putResourceTypeUnique

public <V> ResourceType<V> putResourceTypeUnique(String name,
                                                 ResourceType.DataType<V> dataType)

Specified by:

putResourceTypeUnique in interface GraknGraph

putRuleType

public RuleType putRuleType(String name)

Specified by:

putRuleType in interface GraknGraph

getConceptByBaseIdentifier

public <T extends Concept> T getConceptByBaseIdentifier(Object baseIdentifier)

getConcept

public <T extends Concept> T getConcept(String id)

Specified by:

getConcept in interface GraknGraph

getResourcesByValue

public <V> Collection<Resource<V>> getResourcesByValue(V value)

Specified by:

getResourcesByValue in interface GraknGraph

getType

public Type getType(String name)

Specified by:

getType in interface GraknGraph

getEntityType

public EntityType getEntityType(String name)

Specified by:

getEntityType in interface GraknGraph

getRelationType

public RelationType getRelationType(String name)

Specified by:

getRelationType in interface GraknGraph

getResourceType

public <V> ResourceType<V> getResourceType(String name)

Specified by:

getResourceType in interface GraknGraph

getRoleType

public RoleType getRoleType(String name)

Specified by:

getRoleType in interface GraknGraph

getRuleType

public RuleType getRuleType(String name)

Specified by:

getRuleType in interface GraknGraph

getMetaConcept

public Type getMetaConcept()

Specified by:

getMetaConcept in interface GraknAdmin

getMetaRelationType

public RelationType getMetaRelationType()

Specified by:

getMetaRelationType in interface GraknAdmin

getMetaRoleType

public RoleType getMetaRoleType()

Specified by:

getMetaRoleType in interface GraknAdmin

getMetaResourceType

public ResourceType getMetaResourceType()

Specified by:

getMetaResourceType in interface GraknAdmin

getMetaEntityType

public EntityType getMetaEntityType()

Specified by:

getMetaEntityType in interface GraknAdmin

getMetaRuleType

public RuleType getMetaRuleType()

Specified by:

getMetaRuleType in interface GraknAdmin

getMetaRuleInference

public RuleType getMetaRuleInference()

Specified by:

getMetaRuleInference in interface GraknAdmin

getMetaRuleConstraint

public RuleType getMetaRuleConstraint()

Specified by:

getMetaRuleConstraint in interface GraknAdmin

getRelation

public Relation getRelation(RelationType relationType,
                            Map<RoleType,Instance> roleMap)

Specified by:

getRelation in interface GraknGraph

rollback

public void rollback()

Specified by:

rollback in interface GraknGraph

clear

public void clear()

Clears the graph completely.

Specified by:

clear in interface GraknGraph

clearGraph

protected void clearGraph()

close

public void close()

Closes the current graph, rendering it unusable.

Specified by:

close in interface GraknGraph

Specified by:

close in interface AutoCloseable

closeGraph

public void closeGraph(String closedReason)

finaliseClose

public void finaliseClose(Runnable closer,
                          String closedReason)

closePermanent

public void closePermanent()

commit

public void commit()
            throws GraknValidationException

Commits the graph

Specified by:

commit in interface GraknGraph

Throws:

GraknValidationException - when the graph does not conform to the object concept

commit

public void commit(boolean submitLogs)
            throws GraknValidationException

Throws:

GraknValidationException

commitTx

protected void commitTx()

fixDuplicateCasting

public boolean fixDuplicateCasting(Object castingId)

Merges duplicate castings if one is found.

Parameters:

castingId - The id of the casting to check for duplicates

Returns:

true if some castings were merged

fixDuplicateResources

public boolean fixDuplicateResources(Set<Object> resourceIds)

Parameters:

resourceIds - The resourceIDs which possible contain duplicates.

Returns:

True if a commit is required.