Index

A B C D E F G H I J L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values

A

activeJobs - Variable in class titan.network.RpcWorkerServer

An atomic counter tracking the number of jobs currently being processed by the workerPool.

addLog(String) - Method in class titan.network.LogBatcher

addTaskHandler() - Method in class titan.network.RpcWorkerServer

Initializes and registers various TaskHandler implementations with the worker server.

addWorker(String, int, String, boolean) - Method in class titan.scheduler.WorkerRegistry

Adds a new worker to the registry or updates an existing worker's capabilities and permanence status.

affinityRequired - Variable in class titan.scheduler.Job

appendLogToDisk(String, String) - Method in class titan.scheduler.Scheduler

Appends a log line to a job-specific log file on disk.

applyRoutingConfig() - Method in interface titan.balancer.IngressAdapter

Flushes the current state to the Load Balancer and triggers a hot-reload.

applyRoutingConfig() - Method in class titan.balancer.NginxAdapter

ArchiveInfo(String, String, String) - Constructor for class titan.filesys.AssetManager.ArchiveInfo

assertAffinity(String, String) - Static method in class titan.manual.TitanDAGEndToEnd

assertStatus(String, Job.Status) - Static method in class titan.manual.TitanDAGEndToEnd

AssetManager - Class in titan.filesys

AssetManager() - Constructor for class titan.filesys.AssetManager

AssetManager.ArchiveInfo - Class in titan.filesys

assignedWorker - Variable in class titan.scheduler.TaskExecution

The worker instance to which this task was assigned for execution.

A B C D E F G H I J L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values