A B C D E F G H I J K L M N O P R S T U V W Z

A

addJobCasting(String, String, ConceptId) - Method in class ai.grakn.engine.cache.EngineCacheDistributed

addJobCasting(String, String, ConceptId) - Method in class ai.grakn.engine.cache.EngineCacheStandAlone

addJobInstanceCount(String, TypeLabel, long) - Method in class ai.grakn.engine.cache.EngineCacheDistributed

addJobInstanceCount(String, TypeLabel, long) - Method in class ai.grakn.engine.cache.EngineCacheStandAlone

addJobResource(String, String, ConceptId) - Method in class ai.grakn.engine.cache.EngineCacheDistributed

addJobResource(String, String, ConceptId) - Method in class ai.grakn.engine.cache.EngineCacheStandAlone

addTask(TaskState) - Method in class ai.grakn.engine.tasks.manager.multiqueue.MultiQueueTaskManager

addTask(TaskState) - Method in class ai.grakn.engine.tasks.manager.singlequeue.SingleQueueTaskManager

Create an instance of a task based on the given parameters and submit it a Kafka queue.

addTask(TaskState) - Method in class ai.grakn.engine.tasks.manager.StandaloneTaskManager

addTask(TaskState) - Method in interface ai.grakn.engine.tasks.TaskManager

Schedule a single shot/one off BackgroundTask to run after a @delay in milliseconds.

addUser(Json) - Method in class ai.grakn.engine.user.SystemKeyspaceUsers

Add a new user.

addUser(Json) - Method in class ai.grakn.engine.user.UsersHandler

ai.grakn.engine - package ai.grakn.engine

Implements the REST controllers, task management and post processing features.

ai.grakn.engine.cache - package ai.grakn.engine.cache

ai.grakn.engine.controller - package ai.grakn.engine.controller

Implementation of Grakn server REST endpoints.

ai.grakn.engine.loader - package ai.grakn.engine.loader

Implements LoaderTask.

ai.grakn.engine.postprocessing - package ai.grakn.engine.postprocessing

Implements post-loading graph cleanup processes.

ai.grakn.engine.session - package ai.grakn.engine.session

Severside websocket implementation.

ai.grakn.engine.tasks - package ai.grakn.engine.tasks

ai.grakn.engine.tasks.config - package ai.grakn.engine.tasks.config

ai.grakn.engine.tasks.manager - package ai.grakn.engine.tasks.manager

ai.grakn.engine.tasks.manager.multiqueue - package ai.grakn.engine.tasks.manager.multiqueue

ai.grakn.engine.tasks.manager.singlequeue - package ai.grakn.engine.tasks.manager.singlequeue

ai.grakn.engine.tasks.mock - package ai.grakn.engine.tasks.mock

ai.grakn.engine.tasks.storage - package ai.grakn.engine.tasks.storage

ai.grakn.engine.user - package ai.grakn.engine.user

Implements graph user management.

ai.grakn.engine.util - package ai.grakn.engine.util

Implementation of internal engine utilities.

ai.grakn.factory - package ai.grakn.factory

ALL_ENGINE_PATH - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

ALL_ENGINE_WATCH_PATH - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

allUsers(int, int) - Method in class ai.grakn.engine.user.SystemKeyspaceUsers

Retrieve the list of all users with all their properties.

allUsers(int, int) - Method in class ai.grakn.engine.user.UsersHandler

at(Instant) - Static method in class ai.grakn.engine.tasks.TaskSchedule

Create a schedule to run a task at a specified instant.

AuthController - Class in ai.grakn.engine.controller

Endpoints used to handle operations related to authentication.

AuthController(Service) - Constructor for class ai.grakn.engine.controller.AuthController

await() - Method in class ai.grakn.engine.tasks.manager.singlequeue.TaskFailover

Block until this instance of TaskFailover fails with an unhandled error.

awaitLeader() - Method in class ai.grakn.engine.tasks.manager.singlequeue.FailoverElector

Return the identifier of the current leader.

B

BackgroundTask - Interface in ai.grakn.engine.tasks

Interface which all tasks that wish to be scheduled for later execution as background tasks must implement.

C

cancelled - Variable in class ai.grakn.engine.tasks.mock.MockBackgroundTask

cancelledTasks() - Static method in class ai.grakn.engine.tasks.mock.MockBackgroundTask

checkpoint() - Method in class ai.grakn.engine.tasks.TaskCheckpoint

checkpoint(TaskCheckpoint) - Method in class ai.grakn.engine.tasks.TaskState

checkpoint() - Method in class ai.grakn.engine.tasks.TaskState

childEvent(CuratorFramework, TreeCacheEvent) - Method in class ai.grakn.engine.tasks.manager.singlequeue.TaskFailover

We want to requeue anything that is not on one of the currently running engines

chooseStorage(GraknEngineConfig, ZookeeperConnection) - Method in interface ai.grakn.engine.tasks.TaskManager

clearAllJobs(String) - Method in class ai.grakn.engine.cache.EngineCacheDistributed

clearAllJobs(String) - Method in class ai.grakn.engine.cache.EngineCacheStandAlone

clearCache() - Static method in class ai.grakn.engine.cache.EngineCacheProvider

clearJobSetCastings(String, String) - Method in class ai.grakn.engine.cache.EngineCacheDistributed

clearJobSetCastings(String, String) - Method in class ai.grakn.engine.cache.EngineCacheStandAlone

clearJobSetResources(String, String) - Method in class ai.grakn.engine.cache.EngineCacheDistributed

clearJobSetResources(String, String) - Method in class ai.grakn.engine.cache.EngineCacheStandAlone

clearTasks() - Static method in class ai.grakn.engine.tasks.mock.MockBackgroundTask

clone() - Method in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask.Job

close() - Method in class ai.grakn.engine.GraknEngineServer

close() - Method in class ai.grakn.engine.tasks.manager.multiqueue.MultiQueueTaskManager

close() - Method in class ai.grakn.engine.tasks.manager.multiqueue.MultiQueueTaskRunner

Stop the main loop, causing run() to exit.

close() - Method in class ai.grakn.engine.tasks.manager.multiqueue.Scheduler

Stop the main loop, causing run() to exit.

close() - Method in class ai.grakn.engine.tasks.manager.singlequeue.SingleQueueTaskManager

Close the SingleQueueTaskRunner and .

close() - Method in class ai.grakn.engine.tasks.manager.singlequeue.SingleQueueTaskRunner

Close connection to Kafka and thread pool.

close() - Method in class ai.grakn.engine.tasks.manager.singlequeue.TaskFailover

close() - Method in class ai.grakn.engine.tasks.manager.StandaloneTaskManager

close() - Method in class ai.grakn.engine.tasks.manager.ZookeeperConnection

Close the connection to zookeeper.

close() - Method in class ai.grakn.engine.tasks.TaskIdDeserializer

close() - Method in class ai.grakn.engine.tasks.TaskIdSerializer

close() - Method in class ai.grakn.engine.tasks.TaskStateDeserializer

close() - Method in class ai.grakn.engine.tasks.TaskStateSerializer

CommitLogController - Class in ai.grakn.engine.controller

A controller which core submits commit logs to so we can post-process jobs for cleanup.

CommitLogController(Service) - Constructor for class ai.grakn.engine.controller.CommitLogController

completedTasks() - Static method in class ai.grakn.engine.tasks.mock.MockBackgroundTask

ConceptController - Class in ai.grakn.engine.controller

Endpoints used to query the graph by concept type or identifier

ConceptController(EngineGraknGraphFactory, Service) - Constructor for class ai.grakn.engine.controller.ConceptController

CONFIG_FILE_SYSTEM_PROPERTY - Static variable in class ai.grakn.engine.GraknEngineConfig

ConfigHelper - Class in ai.grakn.engine.tasks.config

Class containing helper methods to retrieve the default configuration for Zookeeper and Kafka consumers & producers

ConfigHelper() - Constructor for class ai.grakn.engine.tasks.config.ConfigHelper

configuration() - Method in class ai.grakn.engine.tasks.TaskState

configure(Map<String, ?>, boolean) - Method in class ai.grakn.engine.tasks.TaskIdDeserializer

configure(Map<String, ?>, boolean) - Method in class ai.grakn.engine.tasks.TaskIdSerializer

configure(Map<String, ?>, boolean) - Method in class ai.grakn.engine.tasks.TaskStateDeserializer

configure(Map<String, ?>, boolean) - Method in class ai.grakn.engine.tasks.TaskStateSerializer

configureSpark(Service, int) - Static method in class ai.grakn.engine.GraknEngineServer

connection() - Method in class ai.grakn.engine.tasks.manager.ZookeeperConnection

Get the connection to zookeeper

containsTask(TaskId) - Method in class ai.grakn.engine.tasks.storage.TaskStateGraphStore

containsTask(TaskId) - Method in class ai.grakn.engine.tasks.storage.TaskStateInMemoryStore

containsTask(TaskId) - Method in class ai.grakn.engine.tasks.storage.TaskStateZookeeperStore

containsTask(TaskId) - Method in interface ai.grakn.engine.tasks.TaskStateStorage

Returns whether the storage contains the given task

copy() - Method in class ai.grakn.engine.tasks.TaskState

CREATED_BY - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

createdAt() - Method in class ai.grakn.engine.tasks.TaskCheckpoint

creator() - Method in class ai.grakn.engine.tasks.TaskState

CURRENT_DIR_SYSTEM_PROPERTY - Static variable in class ai.grakn.engine.GraknEngineConfig

D

DashboardController - Class in ai.grakn.engine.controller

Private endpoints used by dashboard to query by concept type.

DashboardController(EngineGraknGraphFactory, Service) - Constructor for class ai.grakn.engine.controller.DashboardController

DEFAULT_CONFIG_FILE - Static variable in class ai.grakn.engine.GraknEngineConfig

DEFAULT_KEYSPACE_PROPERTY - Static variable in class ai.grakn.engine.GraknEngineConfig

DEFAULT_LOG_CONFIG_FILE - Static variable in class ai.grakn.engine.GraknEngineConfig

DELETE_UNATTACHED_CONFIG - Static variable in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask

DELETE_UNATTACHED_DEFAULT - Static variable in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask

deleteJobCasting(String, String, ConceptId) - Method in class ai.grakn.engine.cache.EngineCacheDistributed

deleteJobCasting(String, String, ConceptId) - Method in class ai.grakn.engine.cache.EngineCacheStandAlone

deleteJobInstanceCount(String, TypeLabel) - Method in class ai.grakn.engine.cache.EngineCacheDistributed

deleteJobInstanceCount(String, TypeLabel) - Method in class ai.grakn.engine.cache.EngineCacheStandAlone

deleteJobResource(String, String, ConceptId) - Method in class ai.grakn.engine.cache.EngineCacheDistributed

deleteJobResource(String, String, ConceptId) - Method in class ai.grakn.engine.cache.EngineCacheStandAlone

deleteUnattached(boolean) - Method in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask.Job

Specify whether resources that are not associated with any entity or relationship should be deleted from the database.

deleteUnattached() - Method in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask.Job

Return true if this job will delete unattached resources and false otherwise.

deserialize(String, byte[]) - Method in class ai.grakn.engine.tasks.TaskIdDeserializer

deserialize(String, byte[]) - Method in class ai.grakn.engine.tasks.TaskStateDeserializer

deserializeFromString(String) - Static method in class ai.grakn.engine.tasks.TaskStateDeserializer

doStage(MapReduce.Stage) - Method in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask.Job

We skip the combine stage and do only MAP and REDUCE.

E

EndlessExecutionMockTask - Class in ai.grakn.engine.tasks.mock

Mocked task that will never end

EndlessExecutionMockTask() - Constructor for class ai.grakn.engine.tasks.mock.EndlessExecutionMockTask

ENGINE_CACHE - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

ENGINE_CACHE_CONCEPT_IDS - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

ENGINE_CACHE_EXACT_JOB - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

ENGINE_CACHE_JOB_TYPE - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

ENGINE_CACHE_KEYSPACES - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

ENGINE_CACHE_TYPE_INSTANCE_COUNT - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

ENGINE_CACHE_UPDATE_TIME - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

ENGINE_ID - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

EngineCacheDistributed - Class in ai.grakn.engine.cache

Engine's internal Concept ID cache

EngineCacheProvider - Class in ai.grakn.engine.cache

Provides the correct engine cache

EngineCacheProvider() - Constructor for class ai.grakn.engine.cache.EngineCacheProvider

EngineCacheStandAlone - Class in ai.grakn.engine.cache

Engine's internal Concept ID cache

EngineGraknGraphFactory - Class in ai.grakn.factory

Engine's internal Graph Factory

engineID() - Method in class ai.grakn.engine.tasks.TaskState

EngineID - Class in ai.grakn.engine.util

Assigns a random ID to the current instance of Engine.

equals(Object) - Method in class ai.grakn.engine.tasks.TaskCheckpoint

equals(Object) - Method in class ai.grakn.engine.util.EngineID

exception() - Method in class ai.grakn.engine.tasks.TaskState

ExceptionWrapper - Class in ai.grakn.engine.util

Utility class to execute a Runnable and log any exceptions thrown without propagating them further.

ExceptionWrapper() - Constructor for class ai.grakn.engine.util.ExceptionWrapper

ExceptionWrapper.RunnableWithExceptions<E extends Exception> - Interface in ai.grakn.engine.util

Function interface that throws exception for use in the noThrow function

executeResumeInner(TaskCheckpoint) - Method in class ai.grakn.engine.tasks.mock.EndlessExecutionMockTask

executeResumeInner(TaskCheckpoint) - Method in class ai.grakn.engine.tasks.mock.FailingMockTask

executeResumeInner(TaskCheckpoint) - Method in class ai.grakn.engine.tasks.mock.LongExecutionMockTask

executeResumeInner(TaskCheckpoint) - Method in class ai.grakn.engine.tasks.mock.MockBackgroundTask

executeResumeInner(TaskCheckpoint) - Method in class ai.grakn.engine.tasks.mock.ShortExecutionMockTask

executeStartInner(TaskId) - Method in class ai.grakn.engine.tasks.mock.EndlessExecutionMockTask

executeStartInner(TaskId) - Method in class ai.grakn.engine.tasks.mock.FailingMockTask

executeStartInner(TaskId) - Method in class ai.grakn.engine.tasks.mock.LongExecutionMockTask

executeStartInner(TaskId) - Method in class ai.grakn.engine.tasks.mock.MockBackgroundTask

executeStartInner(TaskId) - Method in class ai.grakn.engine.tasks.mock.ShortExecutionMockTask

ExternalOffsetStorage - Class in ai.grakn.engine.tasks

Store Kakfa offsets externally in Zookeeper for exactly once processing

ExternalOffsetStorage(ZookeeperConnection) - Constructor for class ai.grakn.engine.tasks.ExternalOffsetStorage

ExternalStorageRebalancer - Class in ai.grakn.engine.tasks.manager

Class that will store the last offsets after a rebalance in an external storage (zookeeper)

extractUserFromJWT(String) - Static method in class ai.grakn.engine.util.JWTHandler

F

FACTORY_ANALYTICS - Static variable in class ai.grakn.engine.GraknEngineConfig

FACTORY_INTERNAL - Static variable in class ai.grakn.engine.GraknEngineConfig

FailingMockTask - Class in ai.grakn.engine.tasks.mock

Mocked task that will throw exception

FailingMockTask() - Constructor for class ai.grakn.engine.tasks.mock.FailingMockTask

FAILOVER - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

FailoverElector - Class in ai.grakn.engine.tasks.manager.singlequeue

The FailoverElector it registers itself with the leadership election and controls the lifecycle of TaskFailover if elected

FailoverElector(EngineID, ZookeeperConnection, TaskStateStorage) - Constructor for class ai.grakn.engine.tasks.manager.singlequeue.FailoverElector

Instantiating a FailoverElector adds this engine to the leadership selection process

G

generateFinalResult(Iterator<KeyValue<String, Long>>) - Method in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask.Job

getAvailableThreads() - Method in class ai.grakn.engine.GraknEngineConfig

getBytes(String) - Static method in class ai.grakn.engine.user.Password

getCache() - Static method in class ai.grakn.engine.cache.EngineCacheProvider

getCache() - Static method in class ai.grakn.engine.cache.EngineCacheStandAlone

getCastingJobs(String) - Method in class ai.grakn.engine.cache.EngineCacheDistributed

getCastingJobs(String) - Method in class ai.grakn.engine.cache.EngineCacheStandAlone

getGraph(String, GraknTxType) - Method in class ai.grakn.factory.EngineGraknGraphFactory

getId() - Method in class ai.grakn.engine.tasks.TaskState

getInstance() - Static method in class ai.grakn.engine.GraknEngineConfig

getInstance() - Static method in class ai.grakn.engine.postprocessing.PostProcessing

getInstance() - Static method in class ai.grakn.engine.user.UsersHandler

getInstance() - Static method in class ai.grakn.factory.EngineGraknGraphFactory

getInstanceCountJobs(String) - Method in class ai.grakn.engine.cache.EngineCacheDistributed

getInstanceCountJobs(String) - Method in class ai.grakn.engine.cache.EngineCacheStandAlone

getKeyspaces() - Method in class ai.grakn.engine.cache.EngineCacheDistributed

getKeyspaces() - Method in class ai.grakn.engine.cache.EngineCacheStandAlone

getLastTimeJobAdded() - Method in class ai.grakn.engine.cache.EngineCacheDistributed

getLastTimeJobAdded() - Method in class ai.grakn.engine.cache.EngineCacheStandAlone

getLogFilePath() - Method in class ai.grakn.engine.GraknEngineConfig

getMemoryKey() - Method in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask.Job

getOffset(TopicPartition) - Method in class ai.grakn.engine.tasks.ExternalOffsetStorage

Get the offset from Zookeeper for the given partition.

getPath(String) - Method in class ai.grakn.engine.GraknEngineConfig

getProperties() - Method in class ai.grakn.engine.GraknEngineConfig

getProperty(String) - Method in class ai.grakn.engine.GraknEngineConfig

getProperty(String, String) - Method in class ai.grakn.engine.GraknEngineConfig

getPropertyAsBool(String) - Method in class ai.grakn.engine.GraknEngineConfig

getPropertyAsInt(String) - Method in class ai.grakn.engine.GraknEngineConfig

getPropertyAsLong(String) - Method in class ai.grakn.engine.GraknEngineConfig

getResourceJobs(String) - Method in class ai.grakn.engine.cache.EngineCacheDistributed

getResourceJobs(String) - Method in class ai.grakn.engine.cache.EngineCacheStandAlone

getScheduler() - Method in class ai.grakn.engine.tasks.manager.multiqueue.SchedulerElector

getState(TaskId) - Method in class ai.grakn.engine.tasks.storage.TaskStateGraphStore

getState(TaskId) - Method in class ai.grakn.engine.tasks.storage.TaskStateInMemoryStore

getState(TaskId) - Method in class ai.grakn.engine.tasks.storage.TaskStateZookeeperStore

Retrieve the TaskState associated with the given ID.

getState(TaskId) - Method in interface ai.grakn.engine.tasks.TaskStateStorage

This is a copy of the internal TaskState object.

getTaskManager() - Method in class ai.grakn.engine.GraknEngineServer

getTasks(TaskStatus, String, String, EngineID, int, int) - Method in class ai.grakn.engine.tasks.storage.TaskStateGraphStore

getTasks(TaskStatus, String, String, EngineID, int, int, Boolean) - Method in class ai.grakn.engine.tasks.storage.TaskStateGraphStore

getTasks(TaskStatus, String, String, EngineID, int, int) - Method in class ai.grakn.engine.tasks.storage.TaskStateInMemoryStore

getTasks(TaskStatus, String, String, EngineID, int, int) - Method in class ai.grakn.engine.tasks.storage.TaskStateZookeeperStore

This implementation will fetch all of the tasks from zookeeper and then filer them out.

getTasks(TaskStatus, String, String, EngineID, int, int) - Method in interface ai.grakn.engine.tasks.TaskStateStorage

Return a Set of Pairs of tasks that match any of the criteria.

getUser(String) - Method in class ai.grakn.engine.user.SystemKeyspaceUsers

Return the user with the specified name as a JSON object where the properties have the same names as the Grakn resource types.

getUser(String) - Method in class ai.grakn.engine.user.UsersHandler

GRAKN_ASCII - Static variable in class ai.grakn.engine.GraknEngineConfig

GraknEngineConfig - Class in ai.grakn.engine

Singleton class used to read config file and make all the settings available to the Grakn Engine classes.

GraknEngineServer - Class in ai.grakn.engine

Main class in charge to start a web server and all the REST controllers.

GraqlController - Class in ai.grakn.engine.controller

Endpoints used to query the graph using Graql and build a HAL, Graql or Json response.

GraqlController(EngineGraknGraphFactory, Service) - Constructor for class ai.grakn.engine.controller.GraqlController

H

hash(char[], byte[]) - Static method in class ai.grakn.engine.user.Password

Returns a salted and hashed password using the provided hash.
Note - side effect: the password is destroyed (the char[] is filled with zeros)

hashCode() - Method in class ai.grakn.engine.tasks.TaskCheckpoint

hashCode() - Method in class ai.grakn.engine.util.EngineID

I

incrementByInterval() - Method in class ai.grakn.engine.tasks.TaskSchedule

Returns a copy of this Schedule that will start a task after the given interval

init(ZookeeperConnection) - Static method in class ai.grakn.engine.cache.EngineCacheDistributed

init(ConceptCache) - Static method in class ai.grakn.engine.cache.EngineCacheProvider

instanceToState(GraknGraph, Instance) - Method in class ai.grakn.engine.tasks.storage.TaskStateGraphStore

Given an instance concept, turn it into a TaskState object.

interval() - Method in class ai.grakn.engine.tasks.TaskSchedule

Get the interval that the task should recur, if it is a recurring task.

isAlive() - Method in class ai.grakn.engine.tasks.manager.singlequeue.TaskFailover

The TaskRunners should only start/add themselves once a failover is alive

isExpectedPassword(char[], byte[], byte[]) - Static method in class ai.grakn.engine.user.Password

Returns true if the given password and salt match the hashed value, false otherwise.
Note - side effect: the password is destroyed (the char[] is filled with zeros)

isPasswordProtected - Static variable in class ai.grakn.engine.GraknEngineServer

isRecurring() - Method in class ai.grakn.engine.tasks.TaskSchedule

Get whether the task is a recurring task.

J

Job() - Constructor for class ai.grakn.engine.postprocessing.ResourceDeduplicationTask.Job

JWT_SECRET_PROPERTY - Static variable in class ai.grakn.engine.GraknEngineConfig

JWTHandler - Class in ai.grakn.engine.util

Retrieves and verifies user data using JWT

JWTHandler() - Constructor for class ai.grakn.engine.util.JWTHandler

K

kafkaConsumer(String) - Static method in class ai.grakn.engine.tasks.config.ConfigHelper

kafkaProducer() - Static method in class ai.grakn.engine.tasks.config.ConfigHelper

KafkaTerms - Interface in ai.grakn.engine.tasks.config

Class containing strings that describe the Kafka queues and groups

keyspace(String) - Method in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask.Job

Specify the keyspace to use for the deduplication job.

KEYSPACE_CONFIG - Static variable in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask

KEYSPACE_DEFAULT - Static variable in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask

L

LOADER_REPEAT_COMMITS - Static variable in class ai.grakn.engine.GraknEngineConfig

LoaderTask - Class in ai.grakn.engine.loader

Task that will load data into a graph.

LoaderTask() - Constructor for class ai.grakn.engine.loader.LoaderTask

LOG_FILE_CONFIG_SYSTEM_PROPERTY - Static variable in class ai.grakn.engine.GraknEngineConfig

LOG_FILE_OUTPUT_SYSTEM_PROPERTY_MAIN - Static variable in class ai.grakn.engine.GraknEngineConfig

LOG_FILE_OUTPUT_SYSTEM_PROPERTY_POST_PROCESSING - Static variable in class ai.grakn.engine.GraknEngineConfig

LOG_LEVEL_SYSTEM_PROPERTY - Static variable in class ai.grakn.engine.GraknEngineConfig

LOG_NAME_POSTPROCESSING_DEFAULT - Static variable in class ai.grakn.engine.GraknEngineConfig

LOG_NAME_POSTPROCESSING_PROPERTY - Static variable in class ai.grakn.engine.GraknEngineConfig

LOG_TOPIC - Static variable in interface ai.grakn.engine.tasks.config.KafkaTerms

LOGGING_FILE_PATH_MAIN - Static variable in class ai.grakn.engine.GraknEngineConfig

LOGGING_FILE_PATH_POST_PROCESSING - Static variable in class ai.grakn.engine.GraknEngineConfig

LOGGING_LEVEL - Static variable in class ai.grakn.engine.GraknEngineConfig

LongExecutionMockTask - Class in ai.grakn.engine.tasks.mock

Mock task that will run for 10 ms

LongExecutionMockTask() - Constructor for class ai.grakn.engine.tasks.mock.LongExecutionMockTask

M

main(String[]) - Static method in class ai.grakn.engine.GraknEngineServer

mainWithServer() - Static method in class ai.grakn.engine.GraknEngineServer

map(Vertex, MapReduce.MapEmitter<String, ConceptId>) - Method in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask.Job

Emit the resoucre index (value + type) mapped to the concept ID of the resource instance.

markCompleted() - Method in class ai.grakn.engine.tasks.TaskState

markFailed(Throwable) - Method in class ai.grakn.engine.tasks.TaskState

markRunning(EngineID) - Method in class ai.grakn.engine.tasks.TaskState

markScheduled() - Method in class ai.grakn.engine.tasks.TaskState

markStopped() - Method in class ai.grakn.engine.tasks.TaskState

me() - Static method in class ai.grakn.engine.util.EngineID

MockBackgroundTask - Class in ai.grakn.engine.tasks.mock

Main task Mock class- keeps track of completed and failed tasks

MockBackgroundTask() - Constructor for class ai.grakn.engine.tasks.mock.MockBackgroundTask

MultiQueueTaskManager - Class in ai.grakn.engine.tasks.manager.multiqueue

Class to manage tasks distributed using Kafka.

MultiQueueTaskManager(EngineID) - Constructor for class ai.grakn.engine.tasks.manager.multiqueue.MultiQueueTaskManager

MultiQueueTaskRunner - Class in ai.grakn.engine.tasks.manager.multiqueue

Picks up tasks from the work queue, runs them and marks them as completed or failed.

MultiQueueTaskRunner(EngineID, TaskStateStorage, ZookeeperConnection) - Constructor for class ai.grakn.engine.tasks.manager.multiqueue.MultiQueueTaskRunner

N

NEW_TASKS_TOPIC - Static variable in interface ai.grakn.engine.tasks.config.KafkaTerms

newConsumer() - Method in class ai.grakn.engine.tasks.manager.singlequeue.SingleQueueTaskManager

Get a new kafka consumer listening on the new tasks topic

newState(TaskState) - Method in class ai.grakn.engine.tasks.storage.TaskStateGraphStore

newState(TaskState) - Method in class ai.grakn.engine.tasks.storage.TaskStateInMemoryStore

newState(TaskState) - Method in class ai.grakn.engine.tasks.storage.TaskStateZookeeperStore

Creates a new task state in Zookeeper

newState(TaskState) - Method in interface ai.grakn.engine.tasks.TaskStateStorage

Create a new task state and store it, returning an ID to later access this task state.

noThrow(ExceptionWrapper.RunnableWithExceptions, String) - Static method in class ai.grakn.engine.util.ExceptionWrapper

now() - Static method in class ai.grakn.engine.tasks.TaskSchedule

Create a schedule to run a task now.

NUM_THREADS_PROPERTY - Static variable in class ai.grakn.engine.GraknEngineConfig

O

of(Json) - Static method in class ai.grakn.engine.tasks.TaskCheckpoint

of(Class<?>, String, TaskSchedule, Json) - Static method in class ai.grakn.engine.tasks.TaskState

of(Class<?>, String, TaskSchedule, Json, TaskId) - Static method in class ai.grakn.engine.tasks.TaskState

of(String) - Static method in class ai.grakn.engine.util.EngineID

onClose(Session, int, String) - Method in class ai.grakn.engine.session.RemoteSession

onConnect(Session) - Method in class ai.grakn.engine.session.RemoteSession

onMessage(Session, String) - Method in class ai.grakn.engine.session.RemoteSession

onPartitionsAssigned(Collection<TopicPartition>) - Method in class ai.grakn.engine.tasks.manager.ExternalStorageRebalancer

Get the offset of the new partition from the external store.

onPartitionsRevoked(Collection<TopicPartition>) - Method in class ai.grakn.engine.tasks.manager.ExternalStorageRebalancer

Save the offset of the current partition in the external store.

open() - Method in class ai.grakn.engine.tasks.manager.StandaloneTaskManager

P

PARTITION_PATH - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

Password - Class in ai.grakn.engine.user

A utility class for hashing user passwords

PASSWORD_PROTECTED_PROPERTY - Static variable in class ai.grakn.engine.GraknEngineConfig

pause() - Method in class ai.grakn.engine.loader.LoaderTask

pause() - Method in class ai.grakn.engine.postprocessing.PostProcessingTask

pause() - Method in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask

pause() - Method in class ai.grakn.engine.postprocessing.UpdatingInstanceCountTask

pause() - Method in interface ai.grakn.engine.tasks.BackgroundTask

Called to suspend the execution of a currently running task.

pause() - Method in class ai.grakn.engine.tasks.mock.EndlessExecutionMockTask

pause() - Method in class ai.grakn.engine.tasks.mock.FailingMockTask

pause() - Method in class ai.grakn.engine.tasks.mock.LongExecutionMockTask

pause() - Method in class ai.grakn.engine.tasks.mock.ShortExecutionMockTask

POST_PROCESSING_DELAY - Static variable in class ai.grakn.engine.GraknEngineConfig

POST_PROCESSING_THREADS - Static variable in class ai.grakn.engine.GraknEngineConfig

PostProcessing - Class in ai.grakn.engine.postprocessing

Post Processing Manager

PostProcessingTask - Class in ai.grakn.engine.postprocessing

Task that control when postprocessing starts.

PostProcessingTask() - Constructor for class ai.grakn.engine.postprocessing.PostProcessingTask

R

rebalanceListener(Consumer, ExternalOffsetStorage) - Static method in class ai.grakn.engine.tasks.manager.ExternalStorageRebalancer

RECUR_INTERVAL - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

recurring(Duration) - Static method in class ai.grakn.engine.tasks.TaskSchedule

Create a schedule to run a task that recurs on an interval.

recurring(Instant, Duration) - Static method in class ai.grakn.engine.tasks.TaskSchedule

Create a schedule to run a task that recurs on an interval, starting at the specified instance.

RECURRING - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

reduce(String, Iterator<ConceptId>, MapReduce.ReduceEmitter<String, Long>) - Method in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask.Job

Here we simply collect all concepts for a key and ask our concept fixer to do its thing.

refreshConnections() - Method in class ai.grakn.factory.EngineGraknGraphFactory

RemoteSession - Class in ai.grakn.engine.session

Web socket for running a Graql shell

RemoteSession() - Constructor for class ai.grakn.engine.session.RemoteSession

removeUser(String) - Method in class ai.grakn.engine.user.SystemKeyspaceUsers

Removes a user with the given username.

removeUser(String) - Method in class ai.grakn.engine.user.UsersHandler

renounce() - Method in class ai.grakn.engine.tasks.manager.singlequeue.FailoverElector

ResourceDeduplicationTask - Class in ai.grakn.engine.postprocessing

This is a task meant to be run periodically to eliminate resource duplication.

ResourceDeduplicationTask() - Constructor for class ai.grakn.engine.postprocessing.ResourceDeduplicationTask

ResourceDeduplicationTask.Job - Class in ai.grakn.engine.postprocessing

The map-reduce job submitted to the GraknGraphComputer that scan the whole set of resources in the graph and reduces by eliminating duplicates.

resume(Consumer<TaskCheckpoint>, TaskCheckpoint) - Method in class ai.grakn.engine.loader.LoaderTask

resume(Consumer<TaskCheckpoint>, TaskCheckpoint) - Method in class ai.grakn.engine.postprocessing.PostProcessingTask

resume(Consumer<TaskCheckpoint>, TaskCheckpoint) - Method in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask

resume(Consumer<TaskCheckpoint>, TaskCheckpoint) - Method in class ai.grakn.engine.postprocessing.UpdatingInstanceCountTask

resume(Consumer<TaskCheckpoint>, TaskCheckpoint) - Method in interface ai.grakn.engine.tasks.BackgroundTask

This method may be called when resuming from a paused state or recovering from a crash or failure of any kind.

resume(Consumer<TaskCheckpoint>, TaskCheckpoint) - Method in class ai.grakn.engine.tasks.mock.MockBackgroundTask

resumedCounter - Static variable in class ai.grakn.engine.tasks.mock.LongExecutionMockTask

resumedCounter - Static variable in class ai.grakn.engine.tasks.mock.ShortExecutionMockTask

run() - Method in class ai.grakn.engine.postprocessing.PostProcessing

run() - Method in class ai.grakn.engine.tasks.manager.multiqueue.MultiQueueTaskRunner

Start the main loop, this will block until a call to close() that wakes up the consumer.

run() - Method in class ai.grakn.engine.tasks.manager.multiqueue.Scheduler

run() - Method in class ai.grakn.engine.tasks.manager.singlequeue.SingleQueueTaskRunner

Poll Kafka for any new tasks.

run() - Method in interface ai.grakn.engine.util.ExceptionWrapper.RunnableWithExceptions

RUN_AT - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

runAt() - Method in class ai.grakn.engine.tasks.TaskSchedule

Get the instant the task is specified to run at.

S

saveOffset(Consumer, TopicPartition) - Method in class ai.grakn.engine.tasks.ExternalOffsetStorage

Save the offset of the given partition in this consumer in zookeeper.

schedule() - Method in class ai.grakn.engine.tasks.TaskState

schedule(TaskSchedule) - Method in class ai.grakn.engine.tasks.TaskState

SCHEDULED_TASK - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

SCHEDULER - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

Scheduler - Class in ai.grakn.engine.tasks.manager.multiqueue

Handle execution of recurring tasks.

Scheduler(TaskStateStorage, ZookeeperConnection) - Constructor for class ai.grakn.engine.tasks.manager.multiqueue.Scheduler

SchedulerElector - Class in ai.grakn.engine.tasks.manager.multiqueue

There is one "Scheduler" that will be constantly running on the "Leader" machine.

SchedulerElector(TaskStateStorage, ZookeeperConnection) - Constructor for class ai.grakn.engine.tasks.manager.multiqueue.SchedulerElector

SCHEDULERS_GROUP - Static variable in interface ai.grakn.engine.tasks.config.KafkaTerms

SERIALISED_TASK - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

serialize(String, TaskId) - Method in class ai.grakn.engine.tasks.TaskIdSerializer

serialize(String, TaskState) - Method in class ai.grakn.engine.tasks.TaskStateSerializer

serializeToString(TaskState) - Static method in class ai.grakn.engine.tasks.TaskStateSerializer

SERVER_HOST_NAME - Static variable in class ai.grakn.engine.GraknEngineConfig

SERVER_PORT_NUMBER - Static variable in class ai.grakn.engine.GraknEngineConfig

setConfigProperty(String, String) - Method in class ai.grakn.engine.GraknEngineConfig

ShortExecutionMockTask - Class in ai.grakn.engine.tasks.mock

Mocked task that will finish nearly instantaneously

ShortExecutionMockTask() - Constructor for class ai.grakn.engine.tasks.mock.ShortExecutionMockTask

signJWT(String) - Static method in class ai.grakn.engine.util.JWTHandler

SINGLE_ENGINE_PATH - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

SINGLE_ENGINE_WATCH_PATH - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

SingleQueueTaskManager - Class in ai.grakn.engine.tasks.manager.singlequeue

TaskManager implementation that operates using a single Kafka queue and controls the lifecycle SingleQueueTaskManager

SingleQueueTaskManager(EngineID) - Constructor for class ai.grakn.engine.tasks.manager.singlequeue.SingleQueueTaskManager

Create a SingleQueueTaskManager The SingleQueueTaskManager implementation must: + Instantiate a connection to zookeeper + Configure and instance of TaskStateStorage + Create and run an instance of SingleQueueTaskRunner + Add oneself to the leader elector by instantiating failoverelector

SingleQueueTaskRunner - Class in ai.grakn.engine.tasks.manager.singlequeue

The SingleQueueTaskRunner is used by the SingleQueueTaskManager to execute tasks from a Kafka queue.

SingleQueueTaskRunner(SingleQueueTaskManager, EngineID, ExternalOffsetStorage, int) - Constructor for class ai.grakn.engine.tasks.manager.singlequeue.SingleQueueTaskRunner

Create a SingleQueueTaskRunner which retrieves tasks from the given and uses the given to store and retrieve information about tasks.

STACK_TRACE - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

stackTrace() - Method in class ai.grakn.engine.tasks.TaskState

StandaloneTaskManager - Class in ai.grakn.engine.tasks.manager

In-memory task manager to schedule and execute tasks.

StandaloneTaskManager(EngineID) - Constructor for class ai.grakn.engine.tasks.manager.StandaloneTaskManager

start(String, int) - Static method in class ai.grakn.engine.GraknEngineServer

start(Consumer<TaskCheckpoint>, Json) - Method in class ai.grakn.engine.loader.LoaderTask

start(Consumer<TaskCheckpoint>, Json) - Method in class ai.grakn.engine.postprocessing.PostProcessingTask

Run postprocessing only if enough time has passed since the last job was added

start(Consumer<TaskCheckpoint>, Json) - Method in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask

start(Consumer<TaskCheckpoint>, Json) - Method in class ai.grakn.engine.postprocessing.UpdatingInstanceCountTask

start(Consumer<TaskCheckpoint>, Json) - Method in interface ai.grakn.engine.tasks.BackgroundTask

Called to start execution of the task, may be called on a newly scheduled or previously stopped task.

start(Consumer<TaskCheckpoint>, Json) - Method in class ai.grakn.engine.tasks.mock.MockBackgroundTask

startedCounter - Static variable in class ai.grakn.engine.tasks.mock.LongExecutionMockTask

startedCounter - Static variable in class ai.grakn.engine.tasks.mock.ShortExecutionMockTask

startHTTP() - Method in class ai.grakn.engine.GraknEngineServer

stateChanged(CuratorFramework, ConnectionState) - Method in class ai.grakn.engine.tasks.manager.multiqueue.SchedulerElector

STATIC_FILES_PATH - Static variable in class ai.grakn.engine.GraknEngineConfig

status() - Method in class ai.grakn.engine.tasks.TaskState

STATUS - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

STATUS_CHANGE_BY - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

STATUS_CHANGE_TIME - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

statusChangeTime() - Method in class ai.grakn.engine.tasks.TaskState

stop() - Method in class ai.grakn.engine.loader.LoaderTask

stop() - Method in class ai.grakn.engine.postprocessing.PostProcessing

stop() - Method in class ai.grakn.engine.postprocessing.PostProcessingTask

stop() - Method in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask

stop() - Method in class ai.grakn.engine.postprocessing.UpdatingInstanceCountTask

stop() - Method in interface ai.grakn.engine.tasks.BackgroundTask

Called to stop execution of the task, may be called on a running or paused task.

stop() - Method in class ai.grakn.engine.tasks.manager.multiqueue.SchedulerElector

When stopping the ClusterManager we must: 1.

stop() - Method in class ai.grakn.engine.tasks.mock.MockBackgroundTask

stopHTTP() - Method in class ai.grakn.engine.GraknEngineServer

stopTask(TaskId) - Method in class ai.grakn.engine.tasks.manager.multiqueue.MultiQueueTaskManager

stopTask(TaskId) - Method in class ai.grakn.engine.tasks.manager.singlequeue.SingleQueueTaskManager

Stop a task from running.

stopTask(TaskId) - Method in class ai.grakn.engine.tasks.manager.singlequeue.SingleQueueTaskRunner

Stop the task if it is executing on this machine

stopTask(TaskId) - Method in class ai.grakn.engine.tasks.manager.StandaloneTaskManager

stopTask(TaskId) - Method in interface ai.grakn.engine.tasks.TaskManager

Stop a Scheduled, Paused or Running task.

storage() - Method in class ai.grakn.engine.tasks.manager.multiqueue.MultiQueueTaskManager

storage() - Method in class ai.grakn.engine.tasks.manager.singlequeue.SingleQueueTaskManager

Access the storage that this instance of TaskManager uses.

storage() - Method in class ai.grakn.engine.tasks.manager.StandaloneTaskManager

storage() - Method in interface ai.grakn.engine.tasks.TaskManager

Return the StateStorage instance that is used by this class.

sync - Variable in class ai.grakn.engine.tasks.mock.MockBackgroundTask

SystemController - Class in ai.grakn.engine.controller

Controller Providing Configs for building Grakn Graphs

SystemController(Service) - Constructor for class ai.grakn.engine.controller.SystemController

SystemKeyspaceUsers - Class in ai.grakn.engine.user

A DAO for managing users in the Grakn system keyspace.

SystemKeyspaceUsers() - Constructor for class ai.grakn.engine.user.SystemKeyspaceUsers

SystemOntologyElements - Interface in ai.grakn.engine.util

Describes the system ontology elements related to task loading

T

takeLeadership(CuratorFramework) - Method in class ai.grakn.engine.tasks.manager.multiqueue.SchedulerElector

On leadership takeover, start a new Scheduler instance and wait for it to complete.

takeLeadership(CuratorFramework) - Method in class ai.grakn.engine.tasks.manager.singlequeue.FailoverElector

Called when this instance of TaskFailover is elected as leader and starts listening for failed engines.

TASK_CHECKPOINT - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

TASK_CLASS_NAME - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

TASK_CONFIGURATION - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

TASK_EXCEPTION - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

TASK_ID - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

TASK_LOCK_SUFFIX - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

TASK_MANAGER_IMPLEMENTATION - Static variable in class ai.grakn.engine.GraknEngineConfig

TASK_RUNNER_GROUP - Static variable in interface ai.grakn.engine.tasks.config.KafkaTerms

TaskCheckpoint - Class in ai.grakn.engine.tasks

Internal checkpoint used to keep track of task execution

taskClass() - Method in class ai.grakn.engine.tasks.TaskState

TaskFailover - Class in ai.grakn.engine.tasks.manager.singlequeue

Re-schedule tasks that were running when an instance of Engine failed

TaskFailover(CuratorFramework, TaskStateStorage, Producer<TaskId, TaskState>) - Constructor for class ai.grakn.engine.tasks.manager.singlequeue.TaskFailover

TaskIdDeserializer - Class in ai.grakn.engine.tasks

Implementation of Deserializer that allows usage of TaskId as kafka queue keys

TaskIdDeserializer() - Constructor for class ai.grakn.engine.tasks.TaskIdDeserializer

TaskIdSerializer - Class in ai.grakn.engine.tasks

Implementation of Serializer that allows usage of TaskId as kafka queue keys

TaskIdSerializer() - Constructor for class ai.grakn.engine.tasks.TaskIdSerializer

TaskManager - Interface in ai.grakn.engine.tasks

The base TaskManager interface.

TASKRUNNER_POLLING_FREQ - Static variable in class ai.grakn.engine.GraknEngineConfig

TASKS_NAMESPACE - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

TASKS_PATH_PREFIX - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

TASKS_STOPPED - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

TASKS_STOPPED_PREFIX - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

TaskSchedule - Class in ai.grakn.engine.tasks

Scheduling information for tasks, contained within a TaskState.

TasksController - Class in ai.grakn.engine.controller

Endpoints used to query and control queued background tasks.

TasksController(Service, TaskManager) - Constructor for class ai.grakn.engine.controller.TasksController

TaskState - Class in ai.grakn.engine.tasks

Internal task state model used to keep track of scheduled tasks.

TaskStateDeserializer - Class in ai.grakn.engine.tasks

Implementation of Serializer that allows usage of TaskState as kafka queue values

TaskStateDeserializer() - Constructor for class ai.grakn.engine.tasks.TaskStateDeserializer

TaskStateGraphStore - Class in ai.grakn.engine.tasks.storage

Implementation of StateStorage that stores task state in the Grakn system graph.

TaskStateGraphStore() - Constructor for class ai.grakn.engine.tasks.storage.TaskStateGraphStore

TaskStateInMemoryStore - Class in ai.grakn.engine.tasks.storage

Implementation of StateStorage that stores task state in memory.

TaskStateInMemoryStore() - Constructor for class ai.grakn.engine.tasks.storage.TaskStateInMemoryStore

TaskStateSerializer - Class in ai.grakn.engine.tasks

Implementation of Serializer that allows usage of TaskState as kafka queue values

TaskStateSerializer() - Constructor for class ai.grakn.engine.tasks.TaskStateSerializer

TaskStateStorage - Interface in ai.grakn.engine.tasks

The base StateStorage interface.

TaskStateZookeeperStore - Class in ai.grakn.engine.tasks.storage

Manages the state of background BackgroundTask in a synchronized manner withing a cluster.

TaskStateZookeeperStore(ZookeeperConnection) - Constructor for class ai.grakn.engine.tasks.storage.TaskStateZookeeperStore

TIME_LAPSE - Static variable in class ai.grakn.engine.GraknEngineConfig

toString() - Method in class ai.grakn.engine.tasks.TaskCheckpoint

toString() - Method in class ai.grakn.engine.tasks.TaskState

toString() - Method in class ai.grakn.engine.util.EngineID

totalElimintated() - Method in class ai.grakn.engine.postprocessing.ResourceDeduplicationTask

U

updateState(TaskState) - Method in class ai.grakn.engine.tasks.storage.TaskStateGraphStore

updateState(TaskState) - Method in class ai.grakn.engine.tasks.storage.TaskStateInMemoryStore

updateState(TaskState) - Method in class ai.grakn.engine.tasks.storage.TaskStateZookeeperStore

Writes a new state to Zookeeper and records the engine that task is running on.

updateState(TaskState) - Method in interface ai.grakn.engine.tasks.TaskStateStorage

Used to update task state.

updateUser(Json) - Method in class ai.grakn.engine.user.SystemKeyspaceUsers

Update a given user.

updateUser(Json) - Method in class ai.grakn.engine.user.UsersHandler

UpdatingInstanceCountTask - Class in ai.grakn.engine.postprocessing

Task that controls when types are updated with their new instance counts

UpdatingInstanceCountTask() - Constructor for class ai.grakn.engine.postprocessing.UpdatingInstanceCountTask

USE_ZOOKEEPER_STORAGE - Static variable in class ai.grakn.engine.GraknEngineConfig

USER_EMAIL - Static variable in class ai.grakn.engine.user.UsersHandler

USER_ENTITY - Static variable in class ai.grakn.engine.user.UsersHandler

USER_FIRST_NAME - Static variable in class ai.grakn.engine.user.UsersHandler

USER_IS_ADMIN - Static variable in class ai.grakn.engine.user.UsersHandler

USER_LAST_NAME - Static variable in class ai.grakn.engine.user.UsersHandler

USER_NAME - Static variable in class ai.grakn.engine.user.UsersHandler

USER_PASSWORD - Static variable in class ai.grakn.engine.user.UsersHandler

USER_SALT - Static variable in class ai.grakn.engine.user.UsersHandler

UserController - Class in ai.grakn.engine.controller

Endpoint used to control user interaction.

UserController(Service) - Constructor for class ai.grakn.engine.controller.UserController

userExists(String) - Method in class ai.grakn.engine.user.SystemKeyspaceUsers

Return true if the user with the specified name exists and false otherwise.

userExists(String) - Method in class ai.grakn.engine.user.UsersHandler

UsersHandler - Class in ai.grakn.engine.user

Class to interact with users stored in the graph.

UsersHandler() - Constructor for class ai.grakn.engine.user.UsersHandler

V

validateUser(String, String) - Method in class ai.grakn.engine.user.SystemKeyspaceUsers

validateUser(String, String) - Method in class ai.grakn.engine.user.UsersHandler

value() - Method in class ai.grakn.engine.util.EngineID

verifyJWT(String) - Static method in class ai.grakn.engine.util.JWTHandler

W

whenTaskFinishes(Consumer<TaskId>) - Static method in class ai.grakn.engine.tasks.mock.MockBackgroundTask

whenTaskResumes(Consumer<TaskCheckpoint>) - Static method in class ai.grakn.engine.tasks.mock.MockBackgroundTask

whenTaskStarts(Consumer<TaskId>) - Static method in class ai.grakn.engine.tasks.mock.MockBackgroundTask

WORK_QUEUE_TOPIC - Static variable in interface ai.grakn.engine.tasks.config.KafkaTerms

Z

ZK_BACKOFF_BASE_SLEEP_TIME - Static variable in class ai.grakn.engine.GraknEngineConfig

ZK_BACKOFF_MAX_RETRIES - Static variable in class ai.grakn.engine.GraknEngineConfig

ZK_CONNECTION_TIMEOUT - Static variable in class ai.grakn.engine.GraknEngineConfig

ZK_ENGINE_TASK_PATH - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

ZK_SERVERS - Static variable in class ai.grakn.engine.GraknEngineConfig

ZK_SESSION_TIMEOUT - Static variable in class ai.grakn.engine.GraknEngineConfig

ZK_TASK_PATH - Static variable in interface ai.grakn.engine.tasks.config.ZookeeperPaths

ZookeeperConnection - Class in ai.grakn.engine.tasks.manager

Task encapsulating the connection to Zookeeper.

ZookeeperConnection() - Constructor for class ai.grakn.engine.tasks.manager.ZookeeperConnection

Start the connection to zookeeper.

ZookeeperPaths - Interface in ai.grakn.engine.tasks.config

Class containing strings that describe the file storage locations in Zookeeper

A B C D E F G H I J K L M N O P R S T U V W Z