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, hasOneof
long 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;