Package org.apache.spark.status.protobuf
Class StoreTypes.TaskData
Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessageV3
org.apache.spark.status.protobuf.StoreTypes.TaskData
- All Implemented Interfaces:
com.google.protobuf.Message
,com.google.protobuf.MessageLite
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,Serializable
,StoreTypes.TaskDataOrBuilder
- Enclosing class:
- StoreTypes
public static final class StoreTypes.TaskData
extends com.google.protobuf.GeneratedMessageV3
implements StoreTypes.TaskDataOrBuilder
Protobuf type
org.apache.spark.status.protobuf.TaskData
- See Also:
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic final class
Protobuf typeorg.apache.spark.status.protobuf.TaskData
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
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 -
Field Summary
Modifier and TypeFieldDescriptionstatic final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
-
Method Summary
Modifier and TypeMethodDescriptionboolean
map<string, string> executor_logs = 16;
boolean
getAccumulatorUpdates
(int index) repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
int
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
getAccumulatorUpdatesOrBuilder
(int index) repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
List<? extends StoreTypes.AccumulableInfoOrBuilder>
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
int
int32 attempt = 3;
static StoreTypes.TaskData
static final com.google.protobuf.Descriptors.Descriptor
long
optional int64 duration = 7;
optional string error_message = 14;
com.google.protobuf.ByteString
optional string error_message = 14;
optional string executor_id = 8;
com.google.protobuf.ByteString
optional string executor_id = 8;
Deprecated.int
map<string, string> executor_logs = 16;
map<string, string> executor_logs = 16;
getExecutorLogsOrDefault
(String key, String defaultValue) map<string, string> executor_logs = 16;
map<string, string> executor_logs = 16;
long
int64 getting_result_time = 18;
getHost()
optional string host = 9;
com.google.protobuf.ByteString
optional string host = 9;
int
getIndex()
int32 index = 2;
long
int64 launch_time = 5;
com.google.protobuf.Parser<StoreTypes.TaskData>
int
int32 partition_id = 4;
long
optional int64 result_fetch_start = 6;
long
int64 scheduler_delay = 17;
int
boolean
bool speculative = 12;
optional string status = 10;
com.google.protobuf.ByteString
optional string status = 10;
long
int64 task_id = 1;
optional string task_locality = 11;
com.google.protobuf.ByteString
optional string task_locality = 11;
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
boolean
optional int64 duration = 7;
boolean
optional string error_message = 14;
boolean
optional string executor_id = 8;
int
hashCode()
boolean
hasHost()
optional string host = 9;
boolean
optional int64 result_fetch_start = 6;
boolean
optional string status = 10;
boolean
optional string task_locality = 11;
boolean
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
final boolean
static StoreTypes.TaskData.Builder
static StoreTypes.TaskData.Builder
newBuilder
(StoreTypes.TaskData prototype) static StoreTypes.TaskData
parseDelimitedFrom
(InputStream input) static StoreTypes.TaskData
parseDelimitedFrom
(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
(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
(InputStream input) static StoreTypes.TaskData
parseFrom
(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static StoreTypes.TaskData
parseFrom
(ByteBuffer data) static StoreTypes.TaskData
parseFrom
(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static com.google.protobuf.Parser<StoreTypes.TaskData>
parser()
void
writeTo
(com.google.protobuf.CodedOutputStream output) Methods inherited from class com.google.protobuf.GeneratedMessageV3
getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, toString
Methods inherited from class com.google.protobuf.AbstractMessageLite
toByteArray, toByteString, writeDelimitedTo, writeTo
Methods inherited from interface com.google.protobuf.MessageLite
toByteArray, toByteString, writeDelimitedTo, writeTo
Methods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
Field Details
-
TASK_ID_FIELD_NUMBER
public static final int TASK_ID_FIELD_NUMBER- See Also:
-
INDEX_FIELD_NUMBER
public static final int INDEX_FIELD_NUMBER- See Also:
-
ATTEMPT_FIELD_NUMBER
public static final int ATTEMPT_FIELD_NUMBER- See Also:
-
PARTITION_ID_FIELD_NUMBER
public static final int PARTITION_ID_FIELD_NUMBER- See Also:
-
LAUNCH_TIME_FIELD_NUMBER
public static final int LAUNCH_TIME_FIELD_NUMBER- See Also:
-
RESULT_FETCH_START_FIELD_NUMBER
public static final int RESULT_FETCH_START_FIELD_NUMBER- See Also:
-
DURATION_FIELD_NUMBER
public static final int DURATION_FIELD_NUMBER- See Also:
-
EXECUTOR_ID_FIELD_NUMBER
public static final int EXECUTOR_ID_FIELD_NUMBER- See Also:
-
HOST_FIELD_NUMBER
public static final int HOST_FIELD_NUMBER- See Also:
-
STATUS_FIELD_NUMBER
public static final int STATUS_FIELD_NUMBER- See Also:
-
TASK_LOCALITY_FIELD_NUMBER
public static final int TASK_LOCALITY_FIELD_NUMBER- See Also:
-
SPECULATIVE_FIELD_NUMBER
public static final int SPECULATIVE_FIELD_NUMBER- See Also:
-
ACCUMULATOR_UPDATES_FIELD_NUMBER
public static final int ACCUMULATOR_UPDATES_FIELD_NUMBER- See Also:
-
ERROR_MESSAGE_FIELD_NUMBER
public static final int ERROR_MESSAGE_FIELD_NUMBER- See Also:
-
TASK_METRICS_FIELD_NUMBER
public static final int TASK_METRICS_FIELD_NUMBER- See Also:
-
EXECUTOR_LOGS_FIELD_NUMBER
public static final int EXECUTOR_LOGS_FIELD_NUMBER- See Also:
-
SCHEDULER_DELAY_FIELD_NUMBER
public static final int SCHEDULER_DELAY_FIELD_NUMBER- See Also:
-
GETTING_RESULT_TIME_FIELD_NUMBER
public static final int GETTING_RESULT_TIME_FIELD_NUMBER- See Also:
-
-
Method Details
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() -
getTaskId
public long getTaskId()int64 task_id = 1;
- Specified by:
getTaskId
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The taskId.
-
getIndex
public int getIndex()int32 index = 2;
- Specified by:
getIndex
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The index.
-
getAttempt
public int getAttempt()int32 attempt = 3;
- Specified by:
getAttempt
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The attempt.
-
getPartitionId
public int getPartitionId()int32 partition_id = 4;
- Specified by:
getPartitionId
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The partitionId.
-
getLaunchTime
public long getLaunchTime()int64 launch_time = 5;
- Specified by:
getLaunchTime
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The launchTime.
-
hasResultFetchStart
public boolean hasResultFetchStart()optional int64 result_fetch_start = 6;
- Specified by:
hasResultFetchStart
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- Whether the resultFetchStart field is set.
-
getResultFetchStart
public long getResultFetchStart()optional int64 result_fetch_start = 6;
- Specified by:
getResultFetchStart
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The resultFetchStart.
-
hasDuration
public boolean hasDuration()optional int64 duration = 7;
- Specified by:
hasDuration
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- Whether the duration field is set.
-
getDuration
public long getDuration()optional int64 duration = 7;
- Specified by:
getDuration
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The duration.
-
hasExecutorId
public boolean hasExecutorId()optional string executor_id = 8;
- Specified by:
hasExecutorId
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- Whether the executorId field is set.
-
getExecutorId
optional string executor_id = 8;
- Specified by:
getExecutorId
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The executorId.
-
getExecutorIdBytes
public com.google.protobuf.ByteString getExecutorIdBytes()optional string executor_id = 8;
- Specified by:
getExecutorIdBytes
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The bytes for executorId.
-
hasHost
public boolean hasHost()optional string host = 9;
- Specified by:
hasHost
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- Whether the host field is set.
-
getHost
optional string host = 9;
- Specified by:
getHost
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The host.
-
getHostBytes
public com.google.protobuf.ByteString getHostBytes()optional string host = 9;
- Specified by:
getHostBytes
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The bytes for host.
-
hasStatus
public boolean hasStatus()optional string status = 10;
- Specified by:
hasStatus
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- Whether the status field is set.
-
getStatus
optional string status = 10;
- Specified by:
getStatus
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The status.
-
getStatusBytes
public com.google.protobuf.ByteString getStatusBytes()optional string status = 10;
- Specified by:
getStatusBytes
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The bytes for status.
-
hasTaskLocality
public boolean hasTaskLocality()optional string task_locality = 11;
- Specified by:
hasTaskLocality
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- Whether the taskLocality field is set.
-
getTaskLocality
optional string task_locality = 11;
- Specified by:
getTaskLocality
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The taskLocality.
-
getTaskLocalityBytes
public com.google.protobuf.ByteString getTaskLocalityBytes()optional string task_locality = 11;
- Specified by:
getTaskLocalityBytes
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The bytes for taskLocality.
-
getSpeculative
public boolean getSpeculative()bool speculative = 12;
- Specified by:
getSpeculative
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The speculative.
-
getAccumulatorUpdatesList
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
- Specified by:
getAccumulatorUpdatesList
in interfaceStoreTypes.TaskDataOrBuilder
-
getAccumulatorUpdatesOrBuilderList
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
- Specified by:
getAccumulatorUpdatesOrBuilderList
in interfaceStoreTypes.TaskDataOrBuilder
-
getAccumulatorUpdatesCount
public int getAccumulatorUpdatesCount()repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
- Specified by:
getAccumulatorUpdatesCount
in interfaceStoreTypes.TaskDataOrBuilder
-
getAccumulatorUpdates
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
- Specified by:
getAccumulatorUpdates
in interfaceStoreTypes.TaskDataOrBuilder
-
getAccumulatorUpdatesOrBuilder
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
- Specified by:
getAccumulatorUpdatesOrBuilder
in interfaceStoreTypes.TaskDataOrBuilder
-
hasErrorMessage
public boolean hasErrorMessage()optional string error_message = 14;
- Specified by:
hasErrorMessage
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- Whether the errorMessage field is set.
-
getErrorMessage
optional string error_message = 14;
- Specified by:
getErrorMessage
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The errorMessage.
-
getErrorMessageBytes
public com.google.protobuf.ByteString getErrorMessageBytes()optional string error_message = 14;
- Specified by:
getErrorMessageBytes
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The bytes for errorMessage.
-
hasTaskMetrics
public boolean hasTaskMetrics()optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
- Specified by:
hasTaskMetrics
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- Whether the taskMetrics field is set.
-
getTaskMetrics
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
- Specified by:
getTaskMetrics
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The taskMetrics.
-
getTaskMetricsOrBuilder
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
- Specified by:
getTaskMetricsOrBuilder
in interfaceStoreTypes.TaskDataOrBuilder
-
getExecutorLogsCount
public int getExecutorLogsCount()Description copied from interface:StoreTypes.TaskDataOrBuilder
map<string, string> executor_logs = 16;
- Specified by:
getExecutorLogsCount
in interfaceStoreTypes.TaskDataOrBuilder
-
containsExecutorLogs
map<string, string> executor_logs = 16;
- Specified by:
containsExecutorLogs
in interfaceStoreTypes.TaskDataOrBuilder
-
getExecutorLogs
Deprecated.UsegetExecutorLogsMap()
instead.- Specified by:
getExecutorLogs
in interfaceStoreTypes.TaskDataOrBuilder
-
getExecutorLogsMap
map<string, string> executor_logs = 16;
- Specified by:
getExecutorLogsMap
in interfaceStoreTypes.TaskDataOrBuilder
-
getExecutorLogsOrDefault
map<string, string> executor_logs = 16;
- Specified by:
getExecutorLogsOrDefault
in interfaceStoreTypes.TaskDataOrBuilder
-
getExecutorLogsOrThrow
map<string, string> executor_logs = 16;
- Specified by:
getExecutorLogsOrThrow
in interfaceStoreTypes.TaskDataOrBuilder
-
getSchedulerDelay
public long getSchedulerDelay()int64 scheduler_delay = 17;
- Specified by:
getSchedulerDelay
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The schedulerDelay.
-
getGettingResultTime
public long getGettingResultTime()int64 getting_result_time = 18;
- Specified by:
getGettingResultTime
in interfaceStoreTypes.TaskDataOrBuilder
- Returns:
- The gettingResultTime.
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3
-
writeTo
- Specified by:
writeTo
in interfacecom.google.protobuf.MessageLite
- Overrides:
writeTo
in classcom.google.protobuf.GeneratedMessageV3
- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()- Specified by:
getSerializedSize
in interfacecom.google.protobuf.MessageLite
- Overrides:
getSerializedSize
in classcom.google.protobuf.GeneratedMessageV3
-
equals
- Specified by:
equals
in interfacecom.google.protobuf.Message
- Overrides:
equals
in classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()- Specified by:
hashCode
in interfacecom.google.protobuf.Message
- Overrides:
hashCode
in classcom.google.protobuf.AbstractMessage
-
parseFrom
public static StoreTypes.TaskData parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StoreTypes.TaskData parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StoreTypes.TaskData parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StoreTypes.TaskData parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StoreTypes.TaskData parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StoreTypes.TaskData parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
- Throws:
IOException
-
parseFrom
public static StoreTypes.TaskData parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
parseDelimitedFrom
- Throws:
IOException
-
parseDelimitedFrom
public static StoreTypes.TaskData parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
parseFrom
public static StoreTypes.TaskData parseFrom(com.google.protobuf.CodedInputStream input) throws IOException - Throws:
IOException
-
parseFrom
public static StoreTypes.TaskData parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
newBuilderForType
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.Message
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.MessageLite
-
newBuilder
-
newBuilder
-
toBuilder
- Specified by:
toBuilder
in interfacecom.google.protobuf.Message
- Specified by:
toBuilder
in interfacecom.google.protobuf.MessageLite
-
getDefaultInstance
-
parser
-
getParserForType
- Specified by:
getParserForType
in interfacecom.google.protobuf.Message
- Specified by:
getParserForType
in interfacecom.google.protobuf.MessageLite
- Overrides:
getParserForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-