Index (Apache Hadoop YARN Application MaWo Core 3.5.0 API)

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

A

AbstractTask - Class in org.apache.hadoop.applications.mawo.server.common: Abstract class for MaWo Task.
AbstractTask() - Constructor for class org.apache.hadoop.applications.mawo.server.common.AbstractTask: AbstractTask constructor.
AbstractTask(TaskId, Map<String, String>, String, long) - Constructor for class org.apache.hadoop.applications.mawo.server.common.AbstractTask: AbstrackTask constructor.
addTask(Task) - Method in interface org.apache.hadoop.applications.mawo.server.common.WorkAssignmentProtocol: Add Task to the list.
AUTO_SHUTDOWN_WORKERS - Static variable in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Property for setting auto shutdown for worker.

C

clone() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus
CLUSTER_MANAGER_URL - Static variable in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Property for resource manager url.
COMPOSITE - Enum constant in enum class org.apache.hadoop.applications.mawo.server.common.TaskType: Its a composite task which consists of multiple simple tasks.
CompositeTask - Class in org.apache.hadoop.applications.mawo.server.common: Composite Task is Task with multiple commands.
CompositeTask() - Constructor for class org.apache.hadoop.applications.mawo.server.common.CompositeTask: Composite Task initializer.
CompositeTask(Task) - Constructor for class org.apache.hadoop.applications.mawo.server.common.CompositeTask: Composite initializer for specific task.
CONFIG_FILE - Static variable in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: MaWo config file name.

D

deRegisterWorker(WorkerId) - Method in interface org.apache.hadoop.applications.mawo.server.common.WorkAssignmentProtocol: De Register worker.
DIE - Enum constant in enum class org.apache.hadoop.applications.mawo.server.common.TaskType: Die Task is to signal for suicide.
DieTask - Class in org.apache.hadoop.applications.mawo.server.common: Die Task is a type of task which indicates app to die.
DieTask() - Constructor for class org.apache.hadoop.applications.mawo.server.common.DieTask: Die Task constructor.

E

equals(Object) - Method in class org.apache.hadoop.applications.mawo.server.common.TaskId
equals(Object) - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus
equals(Object) - Method in class org.apache.hadoop.applications.mawo.server.master.job.JobId
equals(Object) - Method in class org.apache.hadoop.applications.mawo.server.worker.WorkerId
EXPIRE - Enum constant in enum class org.apache.hadoop.applications.mawo.server.common.TaskStatus.State: EXPIRE State refers to when a task is expired.

F

FAILED - Enum constant in enum class org.apache.hadoop.applications.mawo.server.common.TaskStatus.State: FAILED State is assigned when task fails.

G

getAutoShutdownWorkers() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Check if worker auto shutdown feature is enabled.
getClusterManagerURL() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get cluster manager URL.
getConfigsMap() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get MaWo config map.
getEndTime() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Get task end time.
getEnvironment() - Method in class org.apache.hadoop.applications.mawo.server.common.AbstractTask: Get environment for a Task.
getEnvironment() - Method in interface org.apache.hadoop.applications.mawo.server.common.Task: Get Environment of Task.
getExitCode() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Get exitcode of a Task.
getHostname() - Method in class org.apache.hadoop.applications.mawo.server.worker.WorkerId: Get hostname for Worker.
getId() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskId: Getter method for TaskID.
getID() - Method in class org.apache.hadoop.applications.mawo.server.master.job.JobId: Get JobId.
getIPAddress() - Method in class org.apache.hadoop.applications.mawo.server.worker.WorkerId: Get Worker IP address.
getJobBuilderClass() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get job builder class.
getJobId() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskId: Getter method for jobId.
getJobQueueStorageEnabled() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Check if Job Queue Storage is Enabled.
getMasterDrainEventsTimeout() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get Master drain event timeout.
getMasterTasksStatusLogPath() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get Task status log file path on master host.
getNewWorkerId() - Method in interface org.apache.hadoop.applications.mawo.server.common.WorkAssignmentProtocol: Get next workerId to which new task will be assigned.
getRpcHostName() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get RPC Host map.
getRpcServerPort() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get MaWo RPC server Port.
getRunState() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Get status of a Task.
getStartTime() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Get starttime of a Task.
getTaskCmd() - Method in class org.apache.hadoop.applications.mawo.server.common.AbstractTask: Get TaskCmd for a Task.
getTaskCmd() - Method in interface org.apache.hadoop.applications.mawo.server.common.Task: Get Task cmd.
getTaskCMD() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Get Task cmd of a Task.
getTaskId() - Method in class org.apache.hadoop.applications.mawo.server.common.AbstractTask: Get TaskId for a Task.
getTaskId() - Method in interface org.apache.hadoop.applications.mawo.server.common.Task: Get TaskId of a Task.
getTaskId() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Get Task Id.
getTaskState(TaskId) - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Get Task status of a Task.
getTaskType() - Method in class org.apache.hadoop.applications.mawo.server.common.AbstractTask: Get TaskType for a Task.
getTaskType() - Method in interface org.apache.hadoop.applications.mawo.server.common.Task: Get Task type such as Simple, Composite.
getTaskType() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Get Task Type.
getTeardownWorkerValidityInterval() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get Teardown worker validity interval.
getTimeout() - Method in class org.apache.hadoop.applications.mawo.server.common.AbstractTask: Get Timeout for a Task.
getTimeout() - Method in interface org.apache.hadoop.applications.mawo.server.common.Task: Get Task Timeout in seconds.
getWorkerConcurrentTasksLimit() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get number of tasks a worker can run in parallel.
getWorkerId() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Get workerId.
getWorkerId() - Method in class org.apache.hadoop.applications.mawo.server.worker.WorkerId: Get workerId.
getWorkerWhiteListEnv() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get Worker whitelist env params.
getWorkerWorkSpace() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get worker work space.
getZKAcl() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get ZooKeeper Acls.
getZKAddress() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get ZooKeeper Address.
getZKParentPath() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get ZooKeeper parent Path.
getZKRetriesNum() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get ZooKeeper retries number.
getZKRetryIntervalMS() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get ZooKeeper retry interval value in milli seconds.
getZKSessionTimeoutMS() - Method in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Get ZooKeeper session timeout in milli seconds.

H

hashCode() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskId
hashCode() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus
hashCode() - Method in class org.apache.hadoop.applications.mawo.server.master.job.JobId
hashCode() - Method in class org.apache.hadoop.applications.mawo.server.worker.WorkerId

I

INIT - Enum constant in enum class org.apache.hadoop.applications.mawo.server.common.TaskStatus.State: INIT State refers to Task initialization.

J

JOB_BUILDER_CLASS - Static variable in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Property for setting job builder class.
JobId - Class in org.apache.hadoop.applications.mawo.server.master.job: Define MaWo JobId.
JobId() - Constructor for class org.apache.hadoop.applications.mawo.server.master.job.JobId: JobId default constructor.
JobId(int) - Constructor for class org.apache.hadoop.applications.mawo.server.master.job.JobId: JobId constructor with Id.

K

KILLED - Enum constant in enum class org.apache.hadoop.applications.mawo.server.common.TaskStatus.State: KILLED State refers to when a task is killed.

M

MASTER_TASKS_STATUS_LOG_PATH - Static variable in class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Property for task status log path in master node.
MawoConfiguration - Class in org.apache.hadoop.applications.mawo.server.common: MaWo configuration class.
MawoConfiguration() - Constructor for class org.apache.hadoop.applications.mawo.server.common.MawoConfiguration: Mowo configuration initializer.

N

NULL - Enum constant in enum class org.apache.hadoop.applications.mawo.server.common.TaskType: Its a null task.
NullTask - Class in org.apache.hadoop.applications.mawo.server.common: Define Null Task.
NullTask() - Constructor for class org.apache.hadoop.applications.mawo.server.common.NullTask: Null Task initializer.

O

org.apache.hadoop.applications.mawo.server.common - package org.apache.hadoop.applications.mawo.server.common: Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.hadoop.applications.mawo.server.master.job - package org.apache.hadoop.applications.mawo.server.master.job: Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.hadoop.applications.mawo.server.worker - package org.apache.hadoop.applications.mawo.server.worker: Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

R

readFields(DataInput) - Method in class org.apache.hadoop.applications.mawo.server.common.AbstractTask: Read Fields from file.
readFields(DataInput) - Method in class org.apache.hadoop.applications.mawo.server.common.TaskId
readFields(DataInput) - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus
readFields(DataInput) - Method in class org.apache.hadoop.applications.mawo.server.master.job.JobId
readFields(DataInput) - Method in class org.apache.hadoop.applications.mawo.server.worker.WorkerId
registerWorker(WorkerId) - Method in interface org.apache.hadoop.applications.mawo.server.common.WorkAssignmentProtocol: Register Worker.
RUNNING - Enum constant in enum class org.apache.hadoop.applications.mawo.server.common.TaskStatus.State: RUNNING State refers to Task in Running state.

S

sendHeartbeat(WorkerId, TaskStatus[]) - Method in interface org.apache.hadoop.applications.mawo.server.common.WorkAssignmentProtocol: Worker sends heartbeat to Master.
setEndTime() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Set task end time to current time.
setEnvironment(Map<String, String>) - Method in class org.apache.hadoop.applications.mawo.server.common.AbstractTask: Set environment for a Task.
setEnvironment(Map<String, String>) - Method in interface org.apache.hadoop.applications.mawo.server.common.Task: Set Task environment such as {"HOME":"/user/A"}.
setExitCode(int) - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Set exitcode of a Task.
setHostname(Text) - Method in class org.apache.hadoop.applications.mawo.server.worker.WorkerId: Set hostname for Worker.
setRunState(TaskStatus.State) - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Update status of a Task.
setStartTime() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Set current time as start time of a Task.
setTaskCmd(String) - Method in class org.apache.hadoop.applications.mawo.server.common.AbstractTask: Set TaskCmd for a Task.
setTaskCmd(String) - Method in interface org.apache.hadoop.applications.mawo.server.common.Task: Set Task command.
setTaskCMD(String) - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Set Task cmd of a Task.
setTaskId(TaskId) - Method in class org.apache.hadoop.applications.mawo.server.common.AbstractTask: Set Task Id.
setTaskId(TaskId) - Method in interface org.apache.hadoop.applications.mawo.server.common.Task: Set TaskId.
setTaskId(TaskId) - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Set TaskId.
setTaskState(TaskId, TaskStatus.State) - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Set staus of a Task.
setTaskType(String) - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Set Task Type.
setTaskType(TaskType) - Method in class org.apache.hadoop.applications.mawo.server.common.AbstractTask: Set TaskType for a Task.
setTimeout(long) - Method in class org.apache.hadoop.applications.mawo.server.common.AbstractTask: Set Task Timeout in seconds.
setTimeout(long) - Method in interface org.apache.hadoop.applications.mawo.server.common.Task: Set Task Timeout.
setWorkerId(String) - Method in class org.apache.hadoop.applications.mawo.server.worker.WorkerId: Set workerId.
setWorkerId(WorkerId) - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Set WorkerId.
SIMPLE - Enum constant in enum class org.apache.hadoop.applications.mawo.server.common.TaskType: Its a Simple Task.
SimpleTask - Class in org.apache.hadoop.applications.mawo.server.common: Define Simple Task.
SimpleTask() - Constructor for class org.apache.hadoop.applications.mawo.server.common.SimpleTask: Simple Task default initializer.
SimpleTask(Task) - Constructor for class org.apache.hadoop.applications.mawo.server.common.SimpleTask: Set up Simple Task with Task object.
SimpleTask(TaskId, Map<String, String>, String, long) - Constructor for class org.apache.hadoop.applications.mawo.server.common.SimpleTask: Create Simple Task with Task details.
SUCCEEDED - Enum constant in enum class org.apache.hadoop.applications.mawo.server.common.TaskStatus.State: SUCCEEDED State is assigned when task finishes successfully.

T

Task - Interface in org.apache.hadoop.applications.mawo.server.common: Define Task Interface.
TaskId - Class in org.apache.hadoop.applications.mawo.server.common: Defines TaskId for MaWo app.
TaskId() - Constructor for class org.apache.hadoop.applications.mawo.server.common.TaskId: TaskId constructor.
TaskId(JobId, int) - Constructor for class org.apache.hadoop.applications.mawo.server.common.TaskId: TaskId constructor with jobId and taskId.
TaskStatus - Class in org.apache.hadoop.applications.mawo.server.common: Defines TaskStatus for MaWo app.
TaskStatus() - Constructor for class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Task status constructor.
TaskStatus(WorkerId, TaskId, String, String) - Constructor for class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Task status constructor with workerId, TaskId, TaskCmd, TaskType.
TaskStatus(WorkerId, TaskId, TaskStatus.State, String, String) - Constructor for class org.apache.hadoop.applications.mawo.server.common.TaskStatus: Task status constructor with workerId, TaskId, TaskCmd, TaskType and Run State.
TaskStatus.State - Enum Class in org.apache.hadoop.applications.mawo.server.common: Possible Task States.
TaskType - Enum Class in org.apache.hadoop.applications.mawo.server.common: Define MaWo Task Type.
TEARDOWN - Enum constant in enum class org.apache.hadoop.applications.mawo.server.common.TaskType: Teardown Task is a task which runs after all tasks are finished.
TeardownTask - Class in org.apache.hadoop.applications.mawo.server.common: Define Teardown Task.
TeardownTask() - Constructor for class org.apache.hadoop.applications.mawo.server.common.TeardownTask: Teardown task default constructor.
TeardownTask(TaskId, Map<String, String>, String, long) - Constructor for class org.apache.hadoop.applications.mawo.server.common.TeardownTask: Teardown Task constructor.
toString() - Method in class org.apache.hadoop.applications.mawo.server.common.AbstractTask: ToString.
toString() - Method in class org.apache.hadoop.applications.mawo.server.common.TaskId: Print method for TaskId.
toString() - Method in class org.apache.hadoop.applications.mawo.server.master.job.JobId: Print JobId.
toString() - Method in class org.apache.hadoop.applications.mawo.server.worker.WorkerId: Print workerId.

V

valueOf(String) - Static method in enum class org.apache.hadoop.applications.mawo.server.common.TaskStatus.State: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.apache.hadoop.applications.mawo.server.common.TaskType: Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.apache.hadoop.applications.mawo.server.common.TaskStatus.State: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.apache.hadoop.applications.mawo.server.common.TaskType: Returns an array containing the constants of this enum class, in the order they are declared.

W

WorkAssignmentProtocol - Interface in org.apache.hadoop.applications.mawo.server.common: Define work assignment protocol.
WorkerId - Class in org.apache.hadoop.applications.mawo.server.worker: Define WorkerId for Workers.
WorkerId() - Constructor for class org.apache.hadoop.applications.mawo.server.worker.WorkerId: Default constructor for workerId.
write(DataOutput) - Method in class org.apache.hadoop.applications.mawo.server.common.AbstractTask: Write Task.
write(DataOutput) - Method in class org.apache.hadoop.applications.mawo.server.common.TaskId
write(DataOutput) - Method in class org.apache.hadoop.applications.mawo.server.common.TaskStatus
write(DataOutput) - Method in class org.apache.hadoop.applications.mawo.server.master.job.JobId
write(DataOutput) - Method in class org.apache.hadoop.applications.mawo.server.worker.WorkerId

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