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

A

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

Serialize and send the given task to the given kafka queue

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

addTask(TaskState, TaskConfiguration) - Method in interface ai.grakn.engine.tasks.TaskSubmitter

Schedule a BackgroundTask for execution.

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

Add a new user.

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

adjustCount(String, long) - Method in class ai.grakn.engine.tasks.connection.RedisConnection

Adjusts the count for a specific key.

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

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

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

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

Implementation of Grakn server REST endpoints.

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

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

Implements MutatorTask.

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

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

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.connection - package ai.grakn.engine.tasks.connection

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

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.

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, boolean, JWTHandler, UsersHandler) - Constructor for class ai.grakn.engine.controller.AuthController

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

clear() - Static method in class ai.grakn.engine.lock.LockProvider

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.connection.ZookeeperConnection

Close the connection to zookeeper.

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.StandaloneTaskManager

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

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

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

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, String, TaskManager) - 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 - Static variable in class ai.grakn.engine.postprocessing.UpdatingInstanceCountTask

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

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

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

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, GraknEngineConfig, JWTHandler) - Static method in class ai.grakn.engine.GraknEngineServer

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

Get the connection to zookeeper

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

create(Properties) - Static method in class ai.grakn.engine.factory.EngineGraknGraphFactory

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

create() - Static method in class ai.grakn.engine.session.RemoteSession

create(String, EngineGraknGraphFactory) - Static method in class ai.grakn.engine.user.UsersHandler

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

createConfig(String, String) - Static method in class ai.grakn.engine.postprocessing.PostProcessingTask

Helper method which creates the task config needed in order to execute a PP task

createConfig(String, String) - Static method in class ai.grakn.engine.postprocessing.UpdatingInstanceCountTask

Helper method which creates the task config needed in order to execute the updating count task

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

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

createTask(Class) - Static method in class ai.grakn.engine.postprocessing.PostProcessingTask

Helper method which creates PP Task States.

createTask(Class) - Static method in class ai.grakn.engine.postprocessing.UpdatingInstanceCountTask

Helper method which creates PP Task States.

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

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

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

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

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.TaskConfigurationDeserializer

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_ID - Static variable in interface ai.grakn.engine.util.SystemOntologyElements

EngineGraknGraphFactory - Class in ai.grakn.engine.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.tasks.TaskConfiguration

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) - Method in class ai.grakn.engine.util.JWTHandler

F

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

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

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

getConnection() - Static method in class ai.grakn.engine.tasks.connection.RedisConnection

Returns and possibly initliases a connection pool to the redis server.

getCount(String) - Method in class ai.grakn.engine.tasks.connection.RedisConnection

Gets the count for the specified key.

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

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

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

getKeyNumInstances(String, ConceptId) - Static method in class ai.grakn.engine.tasks.connection.RedisConnection

All the valid keys which map to values in the redis cache

getKeyNumShards(String, ConceptId) - Static method in class ai.grakn.engine.tasks.connection.RedisConnection

getLock(String) - Static method in class ai.grakn.engine.lock.LockProvider

Uses the named lock function to retrieve the correct lock

getLockPath() - Method in class ai.grakn.engine.lock.ZookeeperLock

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.

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

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

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

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

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

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

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.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_VERSION_KEY - 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.

GraphMutators - Class in ai.grakn.engine.postprocessing

Abstract class containing utilities for graph mutations

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

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.tasks.TaskConfiguration

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

instantiate(BiFunction<String, Lock, Lock>) - Static method in class ai.grakn.engine.lock.LockProvider

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

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

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)

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

json() - Method in class ai.grakn.engine.tasks.TaskConfiguration

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

K

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

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

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

lock() - Method in class ai.grakn.engine.lock.NonReentrantLock

lock() - Method in class ai.grakn.engine.lock.ZookeeperLock

Acquires the lock.

lockInterruptibly() - Method in class ai.grakn.engine.lock.NonReentrantLock

lockInterruptibly() - Method in class ai.grakn.engine.lock.ZookeeperLock

LockProvider - Class in ai.grakn.engine.lock

Provide the correct locking functionality based on how the LockProvider was created.

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

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

MutatorTask - Class in ai.grakn.engine.loader

Task that will mutate data in a graph.

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

N

newCondition() - Method in class ai.grakn.engine.lock.NonReentrantLock

newCondition() - Method in class ai.grakn.engine.lock.ZookeeperLock

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.

NonReentrantLock - Class in ai.grakn.engine.lock

A non-reentrant lock

NonReentrantLock() - Constructor for class ai.grakn.engine.lock.NonReentrantLock

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(Json) - Static method in class ai.grakn.engine.tasks.TaskConfiguration

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

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

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.

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

onWebSocketText(String) - Method in class ai.grakn.engine.session.RemoteSession

P

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

passwordProtected(UsersHandler) - Static method in class ai.grakn.engine.session.RemoteSession

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

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_TASK_DELAY - Static variable in class ai.grakn.engine.GraknEngineConfig

PostProcessingTask - Class in ai.grakn.engine.postprocessing

Task that control when postprocessing starts.

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

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

properties() - Method in class ai.grakn.engine.factory.EngineGraknGraphFactory

Q

queue() - Method in enum ai.grakn.engine.tasks.TaskState.Priority

R

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

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

redis - Static variable in class ai.grakn.engine.postprocessing.UpdatingInstanceCountTask

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

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

RedisConnection - Class in ai.grakn.engine.tasks.connection

Connection To Redis Server

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.engine.factory.EngineGraknGraphFactory

RemoteSession - Class in ai.grakn.engine.session

Web socket for running a Graql shell

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

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.MutatorTask

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

rethrow(Throwable) - Static method in class ai.grakn.engine.util.ExceptionWrapper

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.

runBatchMutationWithRetry(EngineGraknGraphFactory, String, Consumer<GraknGraph>) - Static method in class ai.grakn.engine.postprocessing.GraphMutators

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

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

serialize(String, TaskConfiguration) - Method in class ai.grakn.engine.tasks.TaskConfigurationSerializer

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) - Method in class ai.grakn.engine.util.JWTHandler

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, GraknEngineConfig) - 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, Consumer<TaskState, TaskConfiguration>) - 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, GraknEngineConfig) - Constructor for class ai.grakn.engine.tasks.manager.StandaloneTaskManager

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

start(Consumer<TaskCheckpoint>, TaskConfiguration, TaskSubmitter) - Method in class ai.grakn.engine.loader.MutatorTask

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

Apply CASTING and RESOURCE post processing jobs the concept ids in the provided configuration

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

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

start(Consumer<TaskCheckpoint>, TaskConfiguration, TaskSubmitter) - 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>, TaskConfiguration, TaskSubmitter) - Method in class ai.grakn.engine.tasks.mock.MockBackgroundTask

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

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

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_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.MutatorTask

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.mock.MockBackgroundTask

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

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.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.

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

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

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(EngineGraknGraphFactory, 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.

SystemOntologyElements - Interface in ai.grakn.engine.util

Describes the system ontology elements related to task loading

T

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

TASK_CLASS_NAME - 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_MANAGER_IMPLEMENTATION - Static variable in class ai.grakn.engine.GraknEngineConfig

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

TaskConfiguration - Class in ai.grakn.engine.tasks

Internal checkpoint used to keep track of task execution

TaskConfigurationDeserializer - Class in ai.grakn.engine.tasks

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

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

TaskConfigurationSerializer - Class in ai.grakn.engine.tasks

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

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

TaskManager - Interface in ai.grakn.engine.tasks

The base TaskManager interface.

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.

TaskState.Priority - Enum in ai.grakn.engine.tasks

The priority of the task which decides which queue the task should go into

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

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

TaskSubmitter - Interface in ai.grakn.engine.tasks

Submits Background Tasks for processing

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

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

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

tryLock() - Method in class ai.grakn.engine.lock.NonReentrantLock

tryLock(long, TimeUnit) - Method in class ai.grakn.engine.lock.NonReentrantLock

tryLock() - Method in class ai.grakn.engine.lock.ZookeeperLock

Acquire the lock if it is available within 1 second of calling.

tryLock(long, TimeUnit) - Method in class ai.grakn.engine.lock.ZookeeperLock

Acquire the lock if it is available within using .

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

U

unlock() - Method in class ai.grakn.engine.lock.NonReentrantLock

unlock() - Method in class ai.grakn.engine.lock.ZookeeperLock

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.

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

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, UsersHandler) - 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(String) - 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

valueOf(String) - Static method in enum ai.grakn.engine.tasks.TaskState.Priority

Returns the enum constant of this type with the specified name.

values() - Static method in enum ai.grakn.engine.tasks.TaskState.Priority

Returns an array containing the constants of this enum type, in the order they are declared.

verifyJWT(String) - 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

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_NAMESPACE - Static variable in class ai.grakn.engine.GraknEngineConfig

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

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

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

Task encapsulating the connection to Zookeeper.

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

Start the connection to zookeeper.

ZookeeperLock - Class in ai.grakn.engine.lock

A fully distributed lock that is globally synchronous.

ZookeeperLock(ZookeeperConnection, String) - Constructor for class ai.grakn.engine.lock.ZookeeperLock

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