Package org.apache.spark.status.protobuf
Class StoreTypes.TaskData
Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessage
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.GeneratedMessage
implements StoreTypes.TaskDataOrBuilder
Protobuf type
org.apache.spark.status.protobuf.TaskData- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final classProtobuf typeorg.apache.spark.status.protobuf.TaskDataNested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage
com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT, BuilderT>>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingT extends com.google.protobuf.Message, T extends Object> -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final int -
Method Summary
Modifier and TypeMethodDescriptionbooleanmap<string, string> executor_logs = 16;booleangetAccumulatorUpdates(int index) repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;intrepeated .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;intint32 attempt = 3;static StoreTypes.TaskDatastatic final com.google.protobuf.Descriptors.Descriptorlongoptional int64 duration = 7;optional string error_message = 14;com.google.protobuf.ByteStringoptional string error_message = 14;optional string executor_id = 8;com.google.protobuf.ByteStringoptional string executor_id = 8;Deprecated.intmap<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;longint64 getting_result_time = 18;getHost()optional string host = 9;com.google.protobuf.ByteStringoptional string host = 9;intgetIndex()int32 index = 2;longint64 launch_time = 5;com.google.protobuf.Parser<StoreTypes.TaskData>intint32 partition_id = 4;longoptional int64 result_fetch_start = 6;longint64 scheduler_delay = 17;intbooleanbool speculative = 12;optional string status = 10;com.google.protobuf.ByteStringoptional string status = 10;longint64 task_id = 1;optional string task_locality = 11;com.google.protobuf.ByteStringoptional string task_locality = 11;optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;booleanoptional int64 duration = 7;booleanoptional string error_message = 14;booleanoptional string executor_id = 8;inthashCode()booleanhasHost()optional string host = 9;booleanoptional int64 result_fetch_start = 6;booleanoptional string status = 10;booleanoptional string task_locality = 11;booleanoptional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;final booleanstatic StoreTypes.TaskData.Builderstatic StoreTypes.TaskData.BuildernewBuilder(StoreTypes.TaskData prototype) static StoreTypes.TaskDataparseDelimitedFrom(InputStream input) static StoreTypes.TaskDataparseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static StoreTypes.TaskDataparseFrom(byte[] data) static StoreTypes.TaskDataparseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static StoreTypes.TaskDataparseFrom(com.google.protobuf.ByteString data) static StoreTypes.TaskDataparseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static StoreTypes.TaskDataparseFrom(com.google.protobuf.CodedInputStream input) static StoreTypes.TaskDataparseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static StoreTypes.TaskDataparseFrom(InputStream input) static StoreTypes.TaskDataparseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static StoreTypes.TaskDataparseFrom(ByteBuffer data) static StoreTypes.TaskDataparseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static com.google.protobuf.Parser<StoreTypes.TaskData>parser()voidwriteTo(com.google.protobuf.CodedOutputStream output) Methods inherited from class com.google.protobuf.GeneratedMessage
getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newFileScopedGeneratedExtension, newMessageScopedGeneratedExtensionMethods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, toStringMethods inherited from class com.google.protobuf.AbstractMessageLite
toByteArray, toByteString, writeDelimitedTo, writeToMethods inherited from interface com.google.protobuf.MessageLite
toByteArray, toByteString, writeDelimitedTo, writeToMethods 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:
getTaskIdin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The taskId.
-
getIndex
public int getIndex()int32 index = 2;- Specified by:
getIndexin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The index.
-
getAttempt
public int getAttempt()int32 attempt = 3;- Specified by:
getAttemptin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The attempt.
-
getPartitionId
public int getPartitionId()int32 partition_id = 4;- Specified by:
getPartitionIdin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The partitionId.
-
getLaunchTime
public long getLaunchTime()int64 launch_time = 5;- Specified by:
getLaunchTimein interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The launchTime.
-
hasResultFetchStart
public boolean hasResultFetchStart()optional int64 result_fetch_start = 6;- Specified by:
hasResultFetchStartin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- Whether the resultFetchStart field is set.
-
getResultFetchStart
public long getResultFetchStart()optional int64 result_fetch_start = 6;- Specified by:
getResultFetchStartin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The resultFetchStart.
-
hasDuration
public boolean hasDuration()optional int64 duration = 7;- Specified by:
hasDurationin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- Whether the duration field is set.
-
getDuration
public long getDuration()optional int64 duration = 7;- Specified by:
getDurationin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The duration.
-
hasExecutorId
public boolean hasExecutorId()optional string executor_id = 8;- Specified by:
hasExecutorIdin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- Whether the executorId field is set.
-
getExecutorId
optional string executor_id = 8;- Specified by:
getExecutorIdin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The executorId.
-
getExecutorIdBytes
public com.google.protobuf.ByteString getExecutorIdBytes()optional string executor_id = 8;- Specified by:
getExecutorIdBytesin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The bytes for executorId.
-
hasHost
public boolean hasHost()optional string host = 9;- Specified by:
hasHostin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- Whether the host field is set.
-
getHost
optional string host = 9;- Specified by:
getHostin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The host.
-
getHostBytes
public com.google.protobuf.ByteString getHostBytes()optional string host = 9;- Specified by:
getHostBytesin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The bytes for host.
-
hasStatus
public boolean hasStatus()optional string status = 10;- Specified by:
hasStatusin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- Whether the status field is set.
-
getStatus
optional string status = 10;- Specified by:
getStatusin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The status.
-
getStatusBytes
public com.google.protobuf.ByteString getStatusBytes()optional string status = 10;- Specified by:
getStatusBytesin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The bytes for status.
-
hasTaskLocality
public boolean hasTaskLocality()optional string task_locality = 11;- Specified by:
hasTaskLocalityin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- Whether the taskLocality field is set.
-
getTaskLocality
optional string task_locality = 11;- Specified by:
getTaskLocalityin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The taskLocality.
-
getTaskLocalityBytes
public com.google.protobuf.ByteString getTaskLocalityBytes()optional string task_locality = 11;- Specified by:
getTaskLocalityBytesin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The bytes for taskLocality.
-
getSpeculative
public boolean getSpeculative()bool speculative = 12;- Specified by:
getSpeculativein interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The speculative.
-
getAccumulatorUpdatesList
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;- Specified by:
getAccumulatorUpdatesListin interfaceStoreTypes.TaskDataOrBuilder
-
getAccumulatorUpdatesOrBuilderList
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;- Specified by:
getAccumulatorUpdatesOrBuilderListin interfaceStoreTypes.TaskDataOrBuilder
-
getAccumulatorUpdatesCount
public int getAccumulatorUpdatesCount()repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;- Specified by:
getAccumulatorUpdatesCountin interfaceStoreTypes.TaskDataOrBuilder
-
getAccumulatorUpdates
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;- Specified by:
getAccumulatorUpdatesin interfaceStoreTypes.TaskDataOrBuilder
-
getAccumulatorUpdatesOrBuilder
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;- Specified by:
getAccumulatorUpdatesOrBuilderin interfaceStoreTypes.TaskDataOrBuilder
-
hasErrorMessage
public boolean hasErrorMessage()optional string error_message = 14;- Specified by:
hasErrorMessagein interfaceStoreTypes.TaskDataOrBuilder- Returns:
- Whether the errorMessage field is set.
-
getErrorMessage
optional string error_message = 14;- Specified by:
getErrorMessagein interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The errorMessage.
-
getErrorMessageBytes
public com.google.protobuf.ByteString getErrorMessageBytes()optional string error_message = 14;- Specified by:
getErrorMessageBytesin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The bytes for errorMessage.
-
hasTaskMetrics
public boolean hasTaskMetrics()optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;- Specified by:
hasTaskMetricsin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- Whether the taskMetrics field is set.
-
getTaskMetrics
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;- Specified by:
getTaskMetricsin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The taskMetrics.
-
getTaskMetricsOrBuilder
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;- Specified by:
getTaskMetricsOrBuilderin interfaceStoreTypes.TaskDataOrBuilder
-
getExecutorLogsCount
public int getExecutorLogsCount()Description copied from interface:StoreTypes.TaskDataOrBuildermap<string, string> executor_logs = 16;- Specified by:
getExecutorLogsCountin interfaceStoreTypes.TaskDataOrBuilder
-
containsExecutorLogs
map<string, string> executor_logs = 16;- Specified by:
containsExecutorLogsin interfaceStoreTypes.TaskDataOrBuilder
-
getExecutorLogs
Deprecated.UsegetExecutorLogsMap()instead.- Specified by:
getExecutorLogsin interfaceStoreTypes.TaskDataOrBuilder
-
getExecutorLogsMap
map<string, string> executor_logs = 16;- Specified by:
getExecutorLogsMapin interfaceStoreTypes.TaskDataOrBuilder
-
getExecutorLogsOrDefault
map<string, string> executor_logs = 16;- Specified by:
getExecutorLogsOrDefaultin interfaceStoreTypes.TaskDataOrBuilder
-
getExecutorLogsOrThrow
map<string, string> executor_logs = 16;- Specified by:
getExecutorLogsOrThrowin interfaceStoreTypes.TaskDataOrBuilder
-
getSchedulerDelay
public long getSchedulerDelay()int64 scheduler_delay = 17;- Specified by:
getSchedulerDelayin interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The schedulerDelay.
-
getGettingResultTime
public long getGettingResultTime()int64 getting_result_time = 18;- Specified by:
getGettingResultTimein interfaceStoreTypes.TaskDataOrBuilder- Returns:
- The gettingResultTime.
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessage
-
writeTo
- Specified by:
writeToin interfacecom.google.protobuf.MessageLite- Overrides:
writeToin classcom.google.protobuf.GeneratedMessage- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()- Specified by:
getSerializedSizein interfacecom.google.protobuf.MessageLite- Overrides:
getSerializedSizein classcom.google.protobuf.GeneratedMessage
-
equals
- Specified by:
equalsin interfacecom.google.protobuf.Message- Overrides:
equalsin classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()- Specified by:
hashCodein interfacecom.google.protobuf.Message- Overrides:
hashCodein 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:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein interfacecom.google.protobuf.MessageLite
-
newBuilder
-
newBuilder
-
toBuilder
- Specified by:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
getDefaultInstance
-
parser
-
getParserForType
- Specified by:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessage
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-