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, hasOneoffindInitializationErrors, getInitializationErrorString, toStringtoByteArray, toByteString, writeDelimitedTo, writeTopublic 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.MessageOrBuildergetUnknownFields in class com.google.protobuf.GeneratedMessageV3public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public long getTaskId()
int64 task_id = 1;getTaskId in interface StoreTypes.TaskDataOrBuilderpublic int getIndex()
int32 index = 2;getIndex in interface StoreTypes.TaskDataOrBuilderpublic int getAttempt()
int32 attempt = 3;getAttempt in interface StoreTypes.TaskDataOrBuilderpublic int getPartitionId()
int32 partition_id = 4;getPartitionId in interface StoreTypes.TaskDataOrBuilderpublic long getLaunchTime()
int64 launch_time = 5;getLaunchTime in interface StoreTypes.TaskDataOrBuilderpublic boolean hasResultFetchStart()
optional int64 result_fetch_start = 6;hasResultFetchStart in interface StoreTypes.TaskDataOrBuilderpublic long getResultFetchStart()
optional int64 result_fetch_start = 6;getResultFetchStart in interface StoreTypes.TaskDataOrBuilderpublic boolean hasDuration()
optional int64 duration = 7;hasDuration in interface StoreTypes.TaskDataOrBuilderpublic long getDuration()
optional int64 duration = 7;getDuration in interface StoreTypes.TaskDataOrBuilderpublic boolean hasExecutorId()
optional string executor_id = 8;hasExecutorId in interface StoreTypes.TaskDataOrBuilderpublic String getExecutorId()
optional string executor_id = 8;getExecutorId in interface StoreTypes.TaskDataOrBuilderpublic com.google.protobuf.ByteString getExecutorIdBytes()
optional string executor_id = 8;getExecutorIdBytes in interface StoreTypes.TaskDataOrBuilderpublic boolean hasHost()
optional string host = 9;hasHost in interface StoreTypes.TaskDataOrBuilderpublic String getHost()
optional string host = 9;getHost in interface StoreTypes.TaskDataOrBuilderpublic com.google.protobuf.ByteString getHostBytes()
optional string host = 9;getHostBytes in interface StoreTypes.TaskDataOrBuilderpublic boolean hasStatus()
optional string status = 10;hasStatus in interface StoreTypes.TaskDataOrBuilderpublic String getStatus()
optional string status = 10;getStatus in interface StoreTypes.TaskDataOrBuilderpublic com.google.protobuf.ByteString getStatusBytes()
optional string status = 10;getStatusBytes in interface StoreTypes.TaskDataOrBuilderpublic boolean hasTaskLocality()
optional string task_locality = 11;hasTaskLocality in interface StoreTypes.TaskDataOrBuilderpublic String getTaskLocality()
optional string task_locality = 11;getTaskLocality in interface StoreTypes.TaskDataOrBuilderpublic com.google.protobuf.ByteString getTaskLocalityBytes()
optional string task_locality = 11;getTaskLocalityBytes in interface StoreTypes.TaskDataOrBuilderpublic boolean getSpeculative()
bool speculative = 12;getSpeculative in interface StoreTypes.TaskDataOrBuilderpublic java.util.List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;getAccumulatorUpdatesList in interface StoreTypes.TaskDataOrBuilderpublic java.util.List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;getAccumulatorUpdatesOrBuilderList in interface StoreTypes.TaskDataOrBuilderpublic int getAccumulatorUpdatesCount()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;getAccumulatorUpdatesCount in interface StoreTypes.TaskDataOrBuilderpublic StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;getAccumulatorUpdates in interface StoreTypes.TaskDataOrBuilderpublic StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;getAccumulatorUpdatesOrBuilder in interface StoreTypes.TaskDataOrBuilderpublic boolean hasErrorMessage()
optional string error_message = 14;hasErrorMessage in interface StoreTypes.TaskDataOrBuilderpublic String getErrorMessage()
optional string error_message = 14;getErrorMessage in interface StoreTypes.TaskDataOrBuilderpublic com.google.protobuf.ByteString getErrorMessageBytes()
optional string error_message = 14;getErrorMessageBytes in interface StoreTypes.TaskDataOrBuilderpublic boolean hasTaskMetrics()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;hasTaskMetrics in interface StoreTypes.TaskDataOrBuilderpublic StoreTypes.TaskMetrics getTaskMetrics()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;getTaskMetrics in interface StoreTypes.TaskDataOrBuilderpublic StoreTypes.TaskMetricsOrBuilder getTaskMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;getTaskMetricsOrBuilder in interface StoreTypes.TaskDataOrBuilderpublic int getExecutorLogsCount()
StoreTypes.TaskDataOrBuildermap<string, string> executor_logs = 16;getExecutorLogsCount in interface StoreTypes.TaskDataOrBuilderpublic 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.TaskDataOrBuilderpublic java.util.Map<String,String> getExecutorLogsMap()
map<string, string> executor_logs = 16;getExecutorLogsMap in interface StoreTypes.TaskDataOrBuilderpublic String getExecutorLogsOrDefault(String key,
String defaultValue)
map<string, string> executor_logs = 16;getExecutorLogsOrDefault in interface StoreTypes.TaskDataOrBuilderpublic String getExecutorLogsOrThrow(String key)
map<string, string> executor_logs = 16;getExecutorLogsOrThrow in interface StoreTypes.TaskDataOrBuilderpublic long getSchedulerDelay()
int64 scheduler_delay = 17;getSchedulerDelay in interface StoreTypes.TaskDataOrBuilderpublic long getGettingResultTime()
int64 getting_result_time = 18;getGettingResultTime in interface StoreTypes.TaskDataOrBuilderpublic final boolean isInitialized()
isInitialized in interface com.google.protobuf.MessageLiteOrBuilderisInitialized in class com.google.protobuf.GeneratedMessageV3public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException
writeTo in interface com.google.protobuf.MessageLitewriteTo in class com.google.protobuf.GeneratedMessageV3java.io.IOExceptionpublic int getSerializedSize()
getSerializedSize in interface com.google.protobuf.MessageLitegetSerializedSize in class com.google.protobuf.GeneratedMessageV3public boolean equals(Object obj)
equals in interface com.google.protobuf.Messageequals in class com.google.protobuf.AbstractMessagepublic int hashCode()
hashCode in interface com.google.protobuf.MessagehashCode in class com.google.protobuf.AbstractMessagepublic static StoreTypes.TaskData parseFrom(java.nio.ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.TaskData parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.TaskData parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.TaskData parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.TaskData parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.TaskData parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.TaskData parseFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.TaskData parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.TaskData parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.TaskData parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.TaskData parseFrom(com.google.protobuf.CodedInputStream input) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.TaskData parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOExceptionpublic StoreTypes.TaskData.Builder newBuilderForType()
newBuilderForType in interface com.google.protobuf.MessagenewBuilderForType in interface com.google.protobuf.MessageLitepublic 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.MessagetoBuilder in interface com.google.protobuf.MessageLitepublic 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.MessagegetParserForType in interface com.google.protobuf.MessageLitegetParserForType in class com.google.protobuf.GeneratedMessageV3public StoreTypes.TaskData getDefaultInstanceForType()
getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuildergetDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder