ai.grakn.graql.internal.analytics

Class BulkResourceMutate<T>

java.lang.Object

ai.grakn.graql.internal.analytics.BulkResourceMutate<T>

public class BulkResourceMutate<T>
extends Object

Methods to deal with persisting values to a Grakn graph during OLAP computations. Each spark executor is thread bound and responsible for a subset of the vertices in the graph. Therefore, an instance of the graph can be held in each executor and the mutations from multiple vertices committed as batches. The need to delete relations in a separate iterations from when new relations are added can also be facilitated.

Each vertex program should instatiate the BulkResourceMutate class at the start of an iteration and call the close method at the end of each iteration. Additionally cleanup must be called in a separate iteration from putValue to ensure that the graph remains sound.

Constructor Summary

Constructors

Constructor and Description
BulkResourceMutate(String keyspace, String resourceTypeId)
BulkResourceMutate(String keyspace, String resourceTypeId, int batchSize)

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkResourceMutate

public BulkResourceMutate(String keyspace,
                          String resourceTypeId)

BulkResourceMutate

public BulkResourceMutate(String keyspace,
                          String resourceTypeId,
                          int batchSize)