public class TaskStatusUtils
extends java.lang.Object
TaskStatus
messages from the Executor back to the Scheduler.Modifier and Type | Method and Description |
---|---|
static void |
sendStatus(ExecutorDriver driver,
TaskState state,
TaskID taskID,
SlaveID slaveID,
ExecutorID executorID,
java.lang.String message,
boolean isHealthy)
Invokes
sendStatus(ExecutorDriver, TaskState, TaskID, SlaveID, ExecutorID, String, boolean) with null
labels and data values. |
static void |
sendStatus(ExecutorDriver driver,
TaskState state,
TaskID taskID,
SlaveID slaveID,
ExecutorID executorID,
java.lang.String message,
boolean isHealthy,
Labels labels,
byte[] data)
Sends a
TaskStatus to the provided driver which contains the provided information. |
public static void sendStatus(ExecutorDriver driver, TaskState state, TaskID taskID, SlaveID slaveID, ExecutorID executorID, java.lang.String message, boolean isHealthy)
sendStatus(ExecutorDriver, TaskState, TaskID, SlaveID, ExecutorID, String, boolean)
with null
labels
and data
values.public static void sendStatus(ExecutorDriver driver, TaskState state, TaskID taskID, SlaveID slaveID, ExecutorID executorID, java.lang.String message, boolean isHealthy, Labels labels, byte[] data)
TaskStatus
to the provided driver
which contains the provided information.