public static interface StoreTypes.TaskDataOrBuilder
extends com.google.protobuf.MessageOrBuilder
| Modifier and Type | Method and Description |
|---|---|
boolean |
containsExecutorLogs(String key)
map<string, string> executor_logs = 16; |
StoreTypes.AccumulableInfo |
getAccumulatorUpdates(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
int |
getAccumulatorUpdatesCount()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
java.util.List<StoreTypes.AccumulableInfo> |
getAccumulatorUpdatesList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
StoreTypes.AccumulableInfoOrBuilder |
getAccumulatorUpdatesOrBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
java.util.List<? extends StoreTypes.AccumulableInfoOrBuilder> |
getAccumulatorUpdatesOrBuilderList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
int |
getAttempt()
int32 attempt = 3; |
long |
getDuration()
optional int64 duration = 7; |
String |
getErrorMessage()
optional string error_message = 14; |
com.google.protobuf.ByteString |
getErrorMessageBytes()
optional string error_message = 14; |
String |
getExecutorId()
optional string executor_id = 8; |
com.google.protobuf.ByteString |
getExecutorIdBytes()
optional string executor_id = 8; |
java.util.Map<String,String> |
getExecutorLogs()
Deprecated.
|
int |
getExecutorLogsCount()
map<string, string> executor_logs = 16; |
java.util.Map<String,String> |
getExecutorLogsMap()
map<string, string> executor_logs = 16; |
String |
getExecutorLogsOrDefault(String key,
String defaultValue)
map<string, string> executor_logs = 16; |
String |
getExecutorLogsOrThrow(String key)
map<string, string> executor_logs = 16; |
long |
getGettingResultTime()
int64 getting_result_time = 18; |
String |
getHost()
optional string host = 9; |
com.google.protobuf.ByteString |
getHostBytes()
optional string host = 9; |
int |
getIndex()
int32 index = 2; |
long |
getLaunchTime()
int64 launch_time = 5; |
int |
getPartitionId()
int32 partition_id = 4; |
long |
getResultFetchStart()
optional int64 result_fetch_start = 6; |
long |
getSchedulerDelay()
int64 scheduler_delay = 17; |
boolean |
getSpeculative()
bool speculative = 12; |
String |
getStatus()
optional string status = 10; |
com.google.protobuf.ByteString |
getStatusBytes()
optional string status = 10; |
long |
getTaskId()
int64 task_id = 1; |
String |
getTaskLocality()
optional string task_locality = 11; |
com.google.protobuf.ByteString |
getTaskLocalityBytes()
optional string task_locality = 11; |
StoreTypes.TaskMetrics |
getTaskMetrics()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15; |
StoreTypes.TaskMetricsOrBuilder |
getTaskMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15; |
boolean |
hasDuration()
optional int64 duration = 7; |
boolean |
hasErrorMessage()
optional string error_message = 14; |
boolean |
hasExecutorId()
optional string executor_id = 8; |
boolean |
hasHost()
optional string host = 9; |
boolean |
hasResultFetchStart()
optional int64 result_fetch_start = 6; |
boolean |
hasStatus()
optional string status = 10; |
boolean |
hasTaskLocality()
optional string task_locality = 11; |
boolean |
hasTaskMetrics()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15; |
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneoflong getTaskId()
int64 task_id = 1;int getIndex()
int32 index = 2;int getAttempt()
int32 attempt = 3;int getPartitionId()
int32 partition_id = 4;long getLaunchTime()
int64 launch_time = 5;boolean hasResultFetchStart()
optional int64 result_fetch_start = 6;long getResultFetchStart()
optional int64 result_fetch_start = 6;boolean hasDuration()
optional int64 duration = 7;long getDuration()
optional int64 duration = 7;boolean hasExecutorId()
optional string executor_id = 8;String getExecutorId()
optional string executor_id = 8;com.google.protobuf.ByteString getExecutorIdBytes()
optional string executor_id = 8;boolean hasHost()
optional string host = 9;String getHost()
optional string host = 9;com.google.protobuf.ByteString getHostBytes()
optional string host = 9;boolean hasStatus()
optional string status = 10;String getStatus()
optional string status = 10;com.google.protobuf.ByteString getStatusBytes()
optional string status = 10;boolean hasTaskLocality()
optional string task_locality = 11;String getTaskLocality()
optional string task_locality = 11;com.google.protobuf.ByteString getTaskLocalityBytes()
optional string task_locality = 11;boolean getSpeculative()
bool speculative = 12;java.util.List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;int getAccumulatorUpdatesCount()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;java.util.List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;boolean hasErrorMessage()
optional string error_message = 14;String getErrorMessage()
optional string error_message = 14;com.google.protobuf.ByteString getErrorMessageBytes()
optional string error_message = 14;boolean hasTaskMetrics()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;StoreTypes.TaskMetrics getTaskMetrics()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;StoreTypes.TaskMetricsOrBuilder getTaskMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;int getExecutorLogsCount()
map<string, string> executor_logs = 16;boolean containsExecutorLogs(String key)
map<string, string> executor_logs = 16;@Deprecated java.util.Map<String,String> getExecutorLogs()
getExecutorLogsMap() instead.java.util.Map<String,String> getExecutorLogsMap()
map<string, string> executor_logs = 16;String getExecutorLogsOrDefault(String key,
String defaultValue)
map<string, string> executor_logs = 16;String getExecutorLogsOrThrow(String key)
map<string, string> executor_logs = 16;long getSchedulerDelay()
int64 scheduler_delay = 17;long getGettingResultTime()
int64 getting_result_time = 18;