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

P

parentServer - Variable in class titan.tasks.ScriptExecutorHandler

A reference to the parent RpcWorkerServer instance.

parentServer - Variable in class titan.tasks.ServiceHandler

A reference to the parent RpcWorkerServer instance.

parseAndSubmitDAG(String) - Method in class titan.network.SchedulerServer

Parses a string containing multiple job definitions for a Directed Acyclic Graph (DAG) and submits each job to the Scheduler.

payload - Variable in class titan.network.TitanProtocol.TitanPacket

The string payload of the received packet.

payload - Variable in class titan.scheduler.Job

PdfConversionHandler - Class in titan.tasks

PdfConversionHandler() - Constructor for class titan.tasks.PdfConversionHandler

PENDING - Enum constant in enum class titan.scheduler.Job.Status

PERM_FILES_DIR - Static variable in class titan.network.SchedulerServer

persistentMap - Static variable in class titan.tasks.ProcessRegistry

An in-memory concurrent map that stores the mapping from a service identifier to its process ID (PID).

port - Variable in class titan.network.LogBatcher

port - Variable in class titan.network.RpcWorkerServer

port - Variable in class titan.network.SchedulerServer

port - Variable in class titan.scheduler.Scheduler

port - Variable in class titan.scheduler.Worker

The port number on which the worker is listening.

port - Variable in class titan.storage.TitanJRedisAdapter

port - Variable in class titan.TitanCLI

The port number of the Titan scheduler to connect to.

port() - Method in class titan.scheduler.Worker

Returns the port number on which the worker is listening.

portBlacklist - Variable in class titan.scheduler.Scheduler

preferredWorkerId - Variable in class titan.scheduler.Job

printHelp() - Method in class titan.TitanCLI

Prints a list of available commands and their basic usage to the console.

printUsage() - Static method in class titan.Main

Prints the correct command-line usage instructions for running the Titan application.

priority - Variable in class titan.scheduler.Job

PRIORITY_HIGH - Static variable in class titan.scheduler.Job

PRIORITY_LOW - Static variable in class titan.scheduler.Job

PRIORITY_NORMAL - Static variable in class titan.scheduler.Job

PROCESS_REGISTRY_FILE - Static variable in class titan.tasks.ProcessRegistry

The name of the file used for persisting the process registry data to disk.

processCommand(String) - Method in class titan.network.RpcWorkerServer

Parses a command payload to determine the task type and data, then dispatches it to the appropriate TaskHandler.

processCommand(TitanProtocol.TitanPacket) - Method in class titan.network.SchedulerServer

Dispatches incoming TitanProtocol.TitanPackets to the appropriate handler method based on their opCode.

processCommandExplicit(String, String) - Method in class titan.network.RpcWorkerServer

Processes a command by explicitly using a provided task type and task data.

ProcessRegistry - Class in titan.tasks

A registry for managing and cleaning up processes, particularly those that might become "zombied" due to abrupt worker node shutdowns or crashes.

ProcessRegistry() - Constructor for class titan.tasks.ProcessRegistry

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

Propagates worker affinity from a completed parent job to its dependent child jobs.

props - Static variable in class titan.TitanConfig

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