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

A

AbstractTaskManager - Class in ai.grakn.engine.backgroundtasks

AbstractTaskManager() - Constructor for class ai.grakn.engine.backgroundtasks.AbstractTaskManager

add(InsertQuery) - Method in class ai.grakn.engine.loader.Loader

Add an insert query to the queue

addJob(String, Json) - Method in class ai.grakn.engine.loader.RESTLoader

addJobCasting(String, Set<String>) - Method in class ai.grakn.engine.postprocessing.Cache

addJobResource(String, Set<String>) - Method in class ai.grakn.engine.postprocessing.Cache

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

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

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

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

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

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

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

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

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

B

BackgroundTask - Interface in ai.grakn.engine.backgroundtasks

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

BackgroundTasksController - Class in ai.grakn.engine.controller

BackgroundTasksController() - Constructor for class ai.grakn.engine.controller.BackgroundTasksController

BATCH_SIZE_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

batchSize - Variable in class ai.grakn.engine.loader.Loader

BlockingLoader - Class in ai.grakn.engine.loader

RESTLoader that submits tasks to locally running engine and performs basic load balancing.

BlockingLoader(String) - Constructor for class ai.grakn.engine.loader.BlockingLoader

C

Cache - Class in ai.grakn.engine.postprocessing

checkForStatusLoop() - Method in class ai.grakn.engine.loader.DistributedLoader

Loop checking the status of the hosts every 30 seconds.

CommitLogController - Class in ai.grakn.engine.controller

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

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

CONFIG_FILE_SYSTEM_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

ConfigProperties - Class in ai.grakn.engine.util

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

CURRENT_DIR_SYSTEM_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

D

DEFAULT_CONFIG_FILE - Static variable in class ai.grakn.engine.util.ConfigProperties

DEFAULT_GRAPH_NAME_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

DEFAULT_LOG_CONFIG_FILE - Static variable in class ai.grakn.engine.util.ConfigProperties

deleteJobCasting(String, String) - Method in class ai.grakn.engine.postprocessing.Cache

deleteJobResource(String, String) - Method in class ai.grakn.engine.postprocessing.Cache

DistributedLoader - Class in ai.grakn.engine.loader

RESTLoader that distributes computation to multiple Grakn Engine instances

DistributedLoader(String, Collection<String>) - Constructor for class ai.grakn.engine.loader.DistributedLoader

E

enqueuedJobs - Variable in class ai.grakn.engine.loader.Loader

errorJobs - Variable in class ai.grakn.engine.loader.Loader

executeRecurring(UUID, BackgroundTask, long, long) - Method in class ai.grakn.engine.backgroundtasks.AbstractTaskManager

executeRecurring(UUID, BackgroundTask, long, long) - Method in class ai.grakn.engine.backgroundtasks.InMemoryTaskManager

executeSingle(UUID, BackgroundTask, long) - Method in class ai.grakn.engine.backgroundtasks.AbstractTaskManager

executeSingle(UUID, BackgroundTask, long) - Method in class ai.grakn.engine.backgroundtasks.InMemoryTaskManager

F

failure() - Method in class ai.grakn.engine.backgroundtasks.TaskState

failure(Throwable) - Method in class ai.grakn.engine.backgroundtasks.TaskState

finishedJobs - Variable in class ai.grakn.engine.loader.Loader

flush() - Method in class ai.grakn.engine.loader.Loader

Load any remaining batches in the queue.

G

getAllTasks() - Method in class ai.grakn.engine.backgroundtasks.InMemoryTaskManager

getAllTasks() - Method in interface ai.grakn.engine.backgroundtasks.TaskManager

Returns a Set of all tasks in the system - this includes Completed, Running, Dead, etc.

getAvailableThreads() - Method in class ai.grakn.engine.util.ConfigProperties

getBatchSize() - Method in class ai.grakn.engine.loader.Loader

getCastingJobs(String) - Method in class ai.grakn.engine.postprocessing.Cache

getCreator() - Method in class ai.grakn.engine.backgroundtasks.TaskState

getDelay() - Method in class ai.grakn.engine.backgroundtasks.TaskState

getException() - Method in class ai.grakn.engine.loader.TransactionState

getExecutingHostname() - Method in class ai.grakn.engine.backgroundtasks.TaskState

getGraph(String) - Method in class ai.grakn.factory.GraphFactory

getGraphBatchLoading(String) - Method in class ai.grakn.factory.GraphFactory

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

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

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

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

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

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

getInterval() - Method in class ai.grakn.engine.backgroundtasks.TaskState

getKeyspaces() - Method in class ai.grakn.engine.postprocessing.Cache

getLastJobFinished() - Method in class ai.grakn.engine.loader.RESTLoader

getLoaderState() - Method in class ai.grakn.engine.loader.RESTLoader

getLoadingJobs() - Method in class ai.grakn.engine.loader.RESTLoader

getLogFilePath() - Method in class ai.grakn.engine.util.ConfigProperties

getName() - Method in class ai.grakn.engine.backgroundtasks.TaskState

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

getPauseState() - Method in class ai.grakn.engine.backgroundtasks.TaskState

getProperties() - Method in class ai.grakn.engine.util.ConfigProperties

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

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

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

getQueuedTime() - Method in class ai.grakn.engine.backgroundtasks.TaskState

getRecurring() - Method in class ai.grakn.engine.backgroundtasks.TaskState

getRepresentation() - Method in class ai.grakn.engine.visualiser.HALConcept

getResourceJobs(String) - Method in class ai.grakn.engine.postprocessing.Cache

getState() - Method in class ai.grakn.engine.loader.TransactionState

getStatus() - Method in class ai.grakn.engine.backgroundtasks.TaskState

getStatus(UUID) - Method in class ai.grakn.engine.loader.RESTLoader

getStatusChangedBy() - Method in class ai.grakn.engine.backgroundtasks.TaskState

getStatusChangeMessage() - Method in class ai.grakn.engine.backgroundtasks.TaskState

getStatusChangeTime() - Method in class ai.grakn.engine.backgroundtasks.TaskState

getTaskExecutionStatus(UUID) - Method in class ai.grakn.engine.backgroundtasks.AbstractTaskManager

getTaskExecutionStatus(UUID) - Method in class ai.grakn.engine.backgroundtasks.InMemoryTaskManager

getTasks(TaskStatus) - Method in class ai.grakn.engine.backgroundtasks.InMemoryTaskManager

getTasks(TaskStatus) - Method in interface ai.grakn.engine.backgroundtasks.TaskManager

Return a Set of all tasks with a matching @TaskStatus.

getTaskState(UUID) - Method in class ai.grakn.engine.backgroundtasks.InMemoryTaskManager

getTaskState(UUID) - Method in interface ai.grakn.engine.backgroundtasks.TaskManager

Return the full TaskState object for a given task, containing full task metadata including the status change messages and reqesterNames as provided in the stopTask/pauseTask/resumeTask and restartTask methods.

GRAKN_ASCII - Static variable in class ai.grakn.engine.util.ConfigProperties

GraknEngineServer - Class in ai.grakn.engine

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

GraknEngineServer() - Constructor for class ai.grakn.engine.GraknEngineServer

GRAPH_BATCH_CONFIG_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

GRAPH_COMPUTER_CONFIG_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

GRAPH_CONFIG_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

GraphFactory - Class in ai.grakn.factory

GraphFactoryController - Class in ai.grakn.engine.controller

REST controller used by GraknGraphFactoryPersistent to retrieve graph configuration for a given graph name.

GraphFactoryController() - Constructor for class ai.grakn.engine.controller.GraphFactoryController

H

HAL_DEGREE_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

HALConcept - Class in ai.grakn.engine.visualiser

Class used to build the HAL representation of a given concept.

HALConcept(Concept, int, boolean, Set<String>) - Constructor for class ai.grakn.engine.visualiser.HALConcept

HALConcept(Concept) - Constructor for class ai.grakn.engine.visualiser.HALConcept

handleError(Exception, int) - Method in class ai.grakn.engine.loader.Loader

I

ImportController - Class in ai.grakn.engine.controller

ImportController() - Constructor for class ai.grakn.engine.controller.ImportController

InMemoryTaskManager - Class in ai.grakn.engine.backgroundtasks

instantiateTask(String) - Method in class ai.grakn.engine.backgroundtasks.AbstractTaskManager

instantiateTask(String) - Method in class ai.grakn.engine.backgroundtasks.InMemoryTaskManager

isFailed() - Method in class ai.grakn.engine.backgroundtasks.TaskState

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

Check if Mindmamps Engine has been started

isSaveInProgress() - Method in class ai.grakn.engine.postprocessing.Cache

L

loadData(String, Json, UUID) - Method in class ai.grakn.engine.loader.RESTLoader

Loader - Class in ai.grakn.engine.loader

RESTLoader to perform bulk loading into the graph

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

LOADER_REPEAT_COMMITS - Static variable in class ai.grakn.engine.util.ConfigProperties

loadingJobs - Variable in class ai.grakn.engine.loader.Loader

LOG_FILE_CONFIG_SYSTEM_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

LOG_FILE_OUTPUT_SYSTEM_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

LOG_LEVEL_SYSTEM_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

LOGGING_FILE_PATH - Static variable in class ai.grakn.engine.util.ConfigProperties

LOGGING_LEVEL - Static variable in class ai.grakn.engine.util.ConfigProperties

M

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

N

NUM_THREADS_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

O

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

P

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

Called to suspend the execution of a currently running task.

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

POLLING_FREQUENCY_PROPERTY - Static variable in class ai.grakn.engine.util.ConfigProperties

PostProcessing - Class in ai.grakn.engine.postprocessing

POSTPROCESSING_DELAY - Static variable in class ai.grakn.engine.util.ConfigProperties

PostProcessingTask - Class in ai.grakn.engine.postprocessing

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

printLoaderState() - Method in class ai.grakn.engine.loader.Loader

Method that logs the current state of loading transactions

PROJECT_VERSION - Static variable in class ai.grakn.engine.util.ConfigProperties

Q

queries - Variable in class ai.grakn.engine.loader.Loader

R

RemoteSession - Class in ai.grakn.engine.session

Web socket for running a Graql shell

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

RemoteSession(Function<String, GraknGraph>) - Constructor for class ai.grakn.engine.session.RemoteSession

RemoteShellController - Class in ai.grakn.engine.controller

RemoteShellController() - Constructor for class ai.grakn.engine.controller.RemoteShellController

render() - Method in class ai.grakn.engine.visualiser.HALConcept

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

resetAvailabilityMap() - Method in class ai.grakn.engine.loader.DistributedLoader

resetJobsTerminated() - Method in class ai.grakn.engine.loader.DistributedLoader

restart() - Method in interface ai.grakn.engine.backgroundtasks.BackgroundTask

Called to restart a task regardless of where it is in its execution.

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

RESTLoader - Class in ai.grakn.engine.loader

Singleton class that handles insert queries received via REST end point.

resume(Map<String, Object>) - Method in interface ai.grakn.engine.backgroundtasks.BackgroundTask

Called to restore state necessary for execution to a previously suspended point by pause() however resume() itself should not aim to resume execution as this will be accomplished by a subsequent call to start().

resume(Map<String, Object>) - Method in class ai.grakn.engine.postprocessing.PostProcessingTask

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

S

saveNewState(TaskState) - Method in class ai.grakn.engine.backgroundtasks.AbstractTaskManager

saveNewState(TaskState) - Method in class ai.grakn.engine.backgroundtasks.InMemoryTaskManager

scheduleRecurringTask(BackgroundTask, long, long) - Method in class ai.grakn.engine.backgroundtasks.AbstractTaskManager

scheduleRecurringTask(BackgroundTask, long, long) - Method in interface ai.grakn.engine.backgroundtasks.TaskManager

Schedule a task for recurring execution at every @period interval and after an initial @delay.

scheduleTask(BackgroundTask, long) - Method in class ai.grakn.engine.backgroundtasks.AbstractTaskManager

scheduleTask(BackgroundTask, long) - Method in interface ai.grakn.engine.backgroundtasks.TaskManager

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

sendQueriesToLoader(Collection<InsertQuery>) - Method in class ai.grakn.engine.loader.BlockingLoader

sendQueriesToLoader(Collection<InsertQuery>) - Method in class ai.grakn.engine.loader.DistributedLoader

sendQueriesToLoader(Collection<InsertQuery>) - Method in class ai.grakn.engine.loader.Loader

Method to load data into the graph.

SERVER_HOST_NAME - Static variable in class ai.grakn.engine.util.ConfigProperties

SERVER_PORT_NUMBER - Static variable in class ai.grakn.engine.util.ConfigProperties

setBatchSize(int) - Method in class ai.grakn.engine.loader.Loader

Set the size of the each transaction in terms of number of vars.

setCreator(String) - Method in class ai.grakn.engine.backgroundtasks.TaskState

setDelay(long) - Method in class ai.grakn.engine.backgroundtasks.TaskState

setException(String) - Method in class ai.grakn.engine.loader.TransactionState

setExecutingHostname(String) - Method in class ai.grakn.engine.backgroundtasks.TaskState

setExecutorSize(int) - Method in class ai.grakn.engine.loader.BlockingLoader

setInterval(long) - Method in class ai.grakn.engine.backgroundtasks.TaskState

setPauseState(Map<String, Object>) - Method in class ai.grakn.engine.backgroundtasks.TaskState

setPollingFrequency(long) - Method in class ai.grakn.engine.loader.DistributedLoader

Amount of time to wait before checking number completed jobs with slaves

setQueuedTime(Date) - Method in class ai.grakn.engine.backgroundtasks.TaskState

setRecurring(Boolean) - Method in class ai.grakn.engine.backgroundtasks.TaskState

setState(TransactionState.State) - Method in class ai.grakn.engine.loader.TransactionState

setStatus(TaskStatus) - Method in class ai.grakn.engine.backgroundtasks.TaskState

setStatusChangedBy(String) - Method in class ai.grakn.engine.backgroundtasks.TaskState

setStatusChangeMessage(String) - Method in class ai.grakn.engine.backgroundtasks.TaskState

setThreadsNumber(int) - Method in class ai.grakn.engine.loader.DistributedLoader

setThreadsNumber(int) - Method in class ai.grakn.engine.loader.Loader

Set the number of thread that will execute insert transactions at a time

start() - Method in interface ai.grakn.engine.backgroundtasks.BackgroundTask

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

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

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

STATIC_FILES_PATH - Static variable in class ai.grakn.engine.util.ConfigProperties

StatusController - Class in ai.grakn.engine.controller

StatusController() - Constructor for class ai.grakn.engine.controller.StatusController

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

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

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

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

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

stopTask(UUID, String, String) - Method in class ai.grakn.engine.backgroundtasks.AbstractTaskManager

stopTask(UUID) - Method in class ai.grakn.engine.backgroundtasks.InMemoryTaskManager

stopTask(UUID, String, String) - Method in interface ai.grakn.engine.backgroundtasks.TaskManager

Stop a Scheduled, Paused or Running task.

T

TaskManager - Interface in ai.grakn.engine.backgroundtasks

TaskState - Class in ai.grakn.engine.backgroundtasks

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

TaskState(String) - Constructor for class ai.grakn.engine.backgroundtasks.TaskState

TaskStatus - Enum in ai.grakn.engine.backgroundtasks

TEST_CONFIG_FILE - Static variable in class ai.grakn.engine.util.ConfigProperties

threadsNumber - Variable in class ai.grakn.engine.loader.Loader

TIME_LAPSE - Static variable in class ai.grakn.engine.util.ConfigProperties

toString() - Method in class ai.grakn.engine.loader.TransactionState

TransactionController - Class in ai.grakn.engine.controller

TransactionController() - Constructor for class ai.grakn.engine.controller.TransactionController

TransactionState - Class in ai.grakn.engine.loader

Class that enumerates the possible states of a transaction and an exception associates with that state if it is an error.

TransactionState(TransactionState.State) - Constructor for class ai.grakn.engine.loader.TransactionState

TransactionState.State - Enum in ai.grakn.engine.loader

V

valueOf(String) - Static method in enum ai.grakn.engine.backgroundtasks.TaskStatus

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

valueOf(String) - Static method in enum ai.grakn.engine.loader.TransactionState.State

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

values() - Static method in enum ai.grakn.engine.backgroundtasks.TaskStatus

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

values() - Static method in enum ai.grakn.engine.loader.TransactionState.State

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

VisualiserController - Class in ai.grakn.engine.controller

VisualiserController() - Constructor for class ai.grakn.engine.controller.VisualiserController

W

waitToFinish() - Method in class ai.grakn.engine.loader.BlockingLoader

waitToFinish() - Method in class ai.grakn.engine.loader.DistributedLoader

Block the main thread until all of the transactions have finished loading

waitToFinish() - Method in class ai.grakn.engine.loader.Loader

Wait for all loading to terminate.

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