public static final class StoreTypes.TaskData extends com.google.protobuf.GeneratedMessageV3 implements StoreTypes.TaskDataOrBuilder
org.apache.spark.status.protobuf.TaskData
Modifier and Type | Class and Description |
---|---|
static class |
StoreTypes.TaskData.Builder
Protobuf type
org.apache.spark.status.protobuf.TaskData |
com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
Modifier and Type | Field and Description |
---|---|
static int |
ACCUMULATOR_UPDATES_FIELD_NUMBER |
static int |
ATTEMPT_FIELD_NUMBER |
static int |
DURATION_FIELD_NUMBER |
static int |
ERROR_MESSAGE_FIELD_NUMBER |
static int |
EXECUTOR_ID_FIELD_NUMBER |
static int |
EXECUTOR_LOGS_FIELD_NUMBER |
static int |
GETTING_RESULT_TIME_FIELD_NUMBER |
static int |
HOST_FIELD_NUMBER |
static int |
INDEX_FIELD_NUMBER |
static int |
LAUNCH_TIME_FIELD_NUMBER |
static int |
PARTITION_ID_FIELD_NUMBER |
static int |
RESULT_FETCH_START_FIELD_NUMBER |
static int |
SCHEDULER_DELAY_FIELD_NUMBER |
static int |
SPECULATIVE_FIELD_NUMBER |
static int |
STATUS_FIELD_NUMBER |
static int |
TASK_ID_FIELD_NUMBER |
static int |
TASK_LOCALITY_FIELD_NUMBER |
static int |
TASK_METRICS_FIELD_NUMBER |
Modifier and Type | Method and Description |
---|---|
boolean |
containsExecutorLogs(String key)
map<string, string> executor_logs = 16; |
boolean |
equals(Object obj) |
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; |
static StoreTypes.TaskData |
getDefaultInstance() |
StoreTypes.TaskData |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
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; |
com.google.protobuf.Parser<StoreTypes.TaskData> |
getParserForType() |
int |
getPartitionId()
int32 partition_id = 4; |
long |
getResultFetchStart()
optional int64 result_fetch_start = 6; |
long |
getSchedulerDelay()
int64 scheduler_delay = 17; |
int |
getSerializedSize() |
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; |
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
boolean |
hasDuration()
optional int64 duration = 7; |
boolean |
hasErrorMessage()
optional string error_message = 14; |
boolean |
hasExecutorId()
optional string executor_id = 8; |
int |
hashCode() |
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; |
boolean |
isInitialized() |
static StoreTypes.TaskData.Builder |
newBuilder() |
static StoreTypes.TaskData.Builder |
newBuilder(StoreTypes.TaskData prototype) |
StoreTypes.TaskData.Builder |
newBuilderForType() |
static StoreTypes.TaskData |
parseDelimitedFrom(java.io.InputStream input) |
static StoreTypes.TaskData |
parseDelimitedFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.TaskData |
parseFrom(byte[] data) |
static StoreTypes.TaskData |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.TaskData |
parseFrom(java.nio.ByteBuffer data) |
static StoreTypes.TaskData |
parseFrom(java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.TaskData |
parseFrom(com.google.protobuf.ByteString data) |
static StoreTypes.TaskData |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.TaskData |
parseFrom(com.google.protobuf.CodedInputStream input) |
static StoreTypes.TaskData |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.TaskData |
parseFrom(java.io.InputStream input) |
static StoreTypes.TaskData |
parseFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<StoreTypes.TaskData> |
parser() |
StoreTypes.TaskData.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof
findInitializationErrors, getInitializationErrorString, toString
toByteArray, toByteString, writeDelimitedTo, writeTo
public static final int TASK_ID_FIELD_NUMBER
public static final int INDEX_FIELD_NUMBER
public static final int ATTEMPT_FIELD_NUMBER
public static final int PARTITION_ID_FIELD_NUMBER
public static final int LAUNCH_TIME_FIELD_NUMBER
public static final int RESULT_FETCH_START_FIELD_NUMBER
public static final int DURATION_FIELD_NUMBER
public static final int EXECUTOR_ID_FIELD_NUMBER
public static final int HOST_FIELD_NUMBER
public static final int STATUS_FIELD_NUMBER
public static final int TASK_LOCALITY_FIELD_NUMBER
public static final int SPECULATIVE_FIELD_NUMBER
public static final int ACCUMULATOR_UPDATES_FIELD_NUMBER
public static final int ERROR_MESSAGE_FIELD_NUMBER
public static final int TASK_METRICS_FIELD_NUMBER
public static final int EXECUTOR_LOGS_FIELD_NUMBER
public static final int SCHEDULER_DELAY_FIELD_NUMBER
public static final int GETTING_RESULT_TIME_FIELD_NUMBER
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
getUnknownFields
in interface com.google.protobuf.MessageOrBuilder
getUnknownFields
in class com.google.protobuf.GeneratedMessageV3
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public long getTaskId()
int64 task_id = 1;
getTaskId
in interface StoreTypes.TaskDataOrBuilder
public int getIndex()
int32 index = 2;
getIndex
in interface StoreTypes.TaskDataOrBuilder
public int getAttempt()
int32 attempt = 3;
getAttempt
in interface StoreTypes.TaskDataOrBuilder
public int getPartitionId()
int32 partition_id = 4;
getPartitionId
in interface StoreTypes.TaskDataOrBuilder
public long getLaunchTime()
int64 launch_time = 5;
getLaunchTime
in interface StoreTypes.TaskDataOrBuilder
public boolean hasResultFetchStart()
optional int64 result_fetch_start = 6;
hasResultFetchStart
in interface StoreTypes.TaskDataOrBuilder
public long getResultFetchStart()
optional int64 result_fetch_start = 6;
getResultFetchStart
in interface StoreTypes.TaskDataOrBuilder
public boolean hasDuration()
optional int64 duration = 7;
hasDuration
in interface StoreTypes.TaskDataOrBuilder
public long getDuration()
optional int64 duration = 7;
getDuration
in interface StoreTypes.TaskDataOrBuilder
public boolean hasExecutorId()
optional string executor_id = 8;
hasExecutorId
in interface StoreTypes.TaskDataOrBuilder
public String getExecutorId()
optional string executor_id = 8;
getExecutorId
in interface StoreTypes.TaskDataOrBuilder
public com.google.protobuf.ByteString getExecutorIdBytes()
optional string executor_id = 8;
getExecutorIdBytes
in interface StoreTypes.TaskDataOrBuilder
public boolean hasHost()
optional string host = 9;
hasHost
in interface StoreTypes.TaskDataOrBuilder
public String getHost()
optional string host = 9;
getHost
in interface StoreTypes.TaskDataOrBuilder
public com.google.protobuf.ByteString getHostBytes()
optional string host = 9;
getHostBytes
in interface StoreTypes.TaskDataOrBuilder
public boolean hasStatus()
optional string status = 10;
hasStatus
in interface StoreTypes.TaskDataOrBuilder
public String getStatus()
optional string status = 10;
getStatus
in interface StoreTypes.TaskDataOrBuilder
public com.google.protobuf.ByteString getStatusBytes()
optional string status = 10;
getStatusBytes
in interface StoreTypes.TaskDataOrBuilder
public boolean hasTaskLocality()
optional string task_locality = 11;
hasTaskLocality
in interface StoreTypes.TaskDataOrBuilder
public String getTaskLocality()
optional string task_locality = 11;
getTaskLocality
in interface StoreTypes.TaskDataOrBuilder
public com.google.protobuf.ByteString getTaskLocalityBytes()
optional string task_locality = 11;
getTaskLocalityBytes
in interface StoreTypes.TaskDataOrBuilder
public boolean getSpeculative()
bool speculative = 12;
getSpeculative
in interface StoreTypes.TaskDataOrBuilder
public java.util.List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
getAccumulatorUpdatesList
in interface StoreTypes.TaskDataOrBuilder
public java.util.List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
getAccumulatorUpdatesOrBuilderList
in interface StoreTypes.TaskDataOrBuilder
public int getAccumulatorUpdatesCount()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
getAccumulatorUpdatesCount
in interface StoreTypes.TaskDataOrBuilder
public StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
getAccumulatorUpdates
in interface StoreTypes.TaskDataOrBuilder
public StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
getAccumulatorUpdatesOrBuilder
in interface StoreTypes.TaskDataOrBuilder
public boolean hasErrorMessage()
optional string error_message = 14;
hasErrorMessage
in interface StoreTypes.TaskDataOrBuilder
public String getErrorMessage()
optional string error_message = 14;
getErrorMessage
in interface StoreTypes.TaskDataOrBuilder
public com.google.protobuf.ByteString getErrorMessageBytes()
optional string error_message = 14;
getErrorMessageBytes
in interface StoreTypes.TaskDataOrBuilder
public boolean hasTaskMetrics()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
hasTaskMetrics
in interface StoreTypes.TaskDataOrBuilder
public StoreTypes.TaskMetrics getTaskMetrics()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
getTaskMetrics
in interface StoreTypes.TaskDataOrBuilder
public StoreTypes.TaskMetricsOrBuilder getTaskMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
getTaskMetricsOrBuilder
in interface StoreTypes.TaskDataOrBuilder
public int getExecutorLogsCount()
StoreTypes.TaskDataOrBuilder
map<string, string> executor_logs = 16;
getExecutorLogsCount
in interface StoreTypes.TaskDataOrBuilder
public boolean containsExecutorLogs(String key)
map<string, string> executor_logs = 16;
containsExecutorLogs
in interface StoreTypes.TaskDataOrBuilder
@Deprecated public java.util.Map<String,String> getExecutorLogs()
getExecutorLogsMap()
instead.getExecutorLogs
in interface StoreTypes.TaskDataOrBuilder
public java.util.Map<String,String> getExecutorLogsMap()
map<string, string> executor_logs = 16;
getExecutorLogsMap
in interface StoreTypes.TaskDataOrBuilder
public String getExecutorLogsOrDefault(String key, String defaultValue)
map<string, string> executor_logs = 16;
getExecutorLogsOrDefault
in interface StoreTypes.TaskDataOrBuilder
public String getExecutorLogsOrThrow(String key)
map<string, string> executor_logs = 16;
getExecutorLogsOrThrow
in interface StoreTypes.TaskDataOrBuilder
public long getSchedulerDelay()
int64 scheduler_delay = 17;
getSchedulerDelay
in interface StoreTypes.TaskDataOrBuilder
public long getGettingResultTime()
int64 getting_result_time = 18;
getGettingResultTime
in interface StoreTypes.TaskDataOrBuilder
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3
public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException
writeTo
in interface com.google.protobuf.MessageLite
writeTo
in class com.google.protobuf.GeneratedMessageV3
java.io.IOException
public int getSerializedSize()
getSerializedSize
in interface com.google.protobuf.MessageLite
getSerializedSize
in class com.google.protobuf.GeneratedMessageV3
public boolean equals(Object obj)
equals
in interface com.google.protobuf.Message
equals
in class com.google.protobuf.AbstractMessage
public int hashCode()
hashCode
in interface com.google.protobuf.Message
hashCode
in class com.google.protobuf.AbstractMessage
public static StoreTypes.TaskData parseFrom(java.nio.ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.TaskData parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.TaskData parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.TaskData parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.TaskData parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.TaskData parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.TaskData parseFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.TaskData parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static StoreTypes.TaskData parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.TaskData parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static StoreTypes.TaskData parseFrom(com.google.protobuf.CodedInputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.TaskData parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public StoreTypes.TaskData.Builder newBuilderForType()
newBuilderForType
in interface com.google.protobuf.Message
newBuilderForType
in interface com.google.protobuf.MessageLite
public static StoreTypes.TaskData.Builder newBuilder()
public static StoreTypes.TaskData.Builder newBuilder(StoreTypes.TaskData prototype)
public StoreTypes.TaskData.Builder toBuilder()
toBuilder
in interface com.google.protobuf.Message
toBuilder
in interface com.google.protobuf.MessageLite
public static StoreTypes.TaskData getDefaultInstance()
public static com.google.protobuf.Parser<StoreTypes.TaskData> parser()
public com.google.protobuf.Parser<StoreTypes.TaskData> getParserForType()
getParserForType
in interface com.google.protobuf.Message
getParserForType
in interface com.google.protobuf.MessageLite
getParserForType
in class com.google.protobuf.GeneratedMessageV3
public StoreTypes.TaskData getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder