public static final class StoreTypes.TaskData.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskData.Builder> implements StoreTypes.TaskDataOrBuilder
org.apache.spark.status.protobuf.TaskData
Modifier and Type | Method and Description |
---|---|
StoreTypes.TaskData.Builder |
addAccumulatorUpdates(int index,
StoreTypes.AccumulableInfo.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
StoreTypes.TaskData.Builder |
addAccumulatorUpdates(int index,
StoreTypes.AccumulableInfo value)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
StoreTypes.TaskData.Builder |
addAccumulatorUpdates(StoreTypes.AccumulableInfo.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
StoreTypes.TaskData.Builder |
addAccumulatorUpdates(StoreTypes.AccumulableInfo value)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
StoreTypes.AccumulableInfo.Builder |
addAccumulatorUpdatesBuilder()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
StoreTypes.AccumulableInfo.Builder |
addAccumulatorUpdatesBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
StoreTypes.TaskData.Builder |
addAllAccumulatorUpdates(Iterable<? extends StoreTypes.AccumulableInfo> values)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
StoreTypes.TaskData.Builder |
addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
StoreTypes.TaskData |
build() |
StoreTypes.TaskData |
buildPartial() |
StoreTypes.TaskData.Builder |
clear() |
StoreTypes.TaskData.Builder |
clearAccumulatorUpdates()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
StoreTypes.TaskData.Builder |
clearAttempt()
int32 attempt = 3; |
StoreTypes.TaskData.Builder |
clearDuration()
optional int64 duration = 7; |
StoreTypes.TaskData.Builder |
clearErrorMessage()
optional string error_message = 14; |
StoreTypes.TaskData.Builder |
clearExecutorId()
optional string executor_id = 8; |
StoreTypes.TaskData.Builder |
clearExecutorLogs() |
StoreTypes.TaskData.Builder |
clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
StoreTypes.TaskData.Builder |
clearGettingResultTime()
int64 getting_result_time = 18; |
StoreTypes.TaskData.Builder |
clearHost()
optional string host = 9; |
StoreTypes.TaskData.Builder |
clearIndex()
int32 index = 2; |
StoreTypes.TaskData.Builder |
clearLaunchTime()
int64 launch_time = 5; |
StoreTypes.TaskData.Builder |
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
StoreTypes.TaskData.Builder |
clearPartitionId()
int32 partition_id = 4; |
StoreTypes.TaskData.Builder |
clearResultFetchStart()
optional int64 result_fetch_start = 6; |
StoreTypes.TaskData.Builder |
clearSchedulerDelay()
int64 scheduler_delay = 17; |
StoreTypes.TaskData.Builder |
clearSpeculative()
bool speculative = 12; |
StoreTypes.TaskData.Builder |
clearStatus()
optional string status = 10; |
StoreTypes.TaskData.Builder |
clearTaskId()
int64 task_id = 1; |
StoreTypes.TaskData.Builder |
clearTaskLocality()
optional string task_locality = 11; |
StoreTypes.TaskData.Builder |
clearTaskMetrics()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15; |
StoreTypes.TaskData.Builder |
clone() |
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; |
StoreTypes.AccumulableInfo.Builder |
getAccumulatorUpdatesBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
java.util.List<StoreTypes.AccumulableInfo.Builder> |
getAccumulatorUpdatesBuilderList()
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; |
StoreTypes.TaskData |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
com.google.protobuf.Descriptors.Descriptor |
getDescriptorForType() |
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; |
java.util.Map<String,String> |
getMutableExecutorLogs()
Deprecated.
|
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.TaskMetrics.Builder |
getTaskMetricsBuilder()
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; |
boolean |
isInitialized() |
StoreTypes.TaskData.Builder |
mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
StoreTypes.TaskData.Builder |
mergeFrom(com.google.protobuf.Message other) |
StoreTypes.TaskData.Builder |
mergeFrom(StoreTypes.TaskData other) |
StoreTypes.TaskData.Builder |
mergeTaskMetrics(StoreTypes.TaskMetrics value)
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15; |
StoreTypes.TaskData.Builder |
mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
StoreTypes.TaskData.Builder |
putAllExecutorLogs(java.util.Map<String,String> values)
map<string, string> executor_logs = 16; |
StoreTypes.TaskData.Builder |
putExecutorLogs(String key,
String value)
map<string, string> executor_logs = 16; |
StoreTypes.TaskData.Builder |
removeAccumulatorUpdates(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
StoreTypes.TaskData.Builder |
removeExecutorLogs(String key)
map<string, string> executor_logs = 16; |
StoreTypes.TaskData.Builder |
setAccumulatorUpdates(int index,
StoreTypes.AccumulableInfo.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
StoreTypes.TaskData.Builder |
setAccumulatorUpdates(int index,
StoreTypes.AccumulableInfo value)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
StoreTypes.TaskData.Builder |
setAttempt(int value)
int32 attempt = 3; |
StoreTypes.TaskData.Builder |
setDuration(long value)
optional int64 duration = 7; |
StoreTypes.TaskData.Builder |
setErrorMessage(String value)
optional string error_message = 14; |
StoreTypes.TaskData.Builder |
setErrorMessageBytes(com.google.protobuf.ByteString value)
optional string error_message = 14; |
StoreTypes.TaskData.Builder |
setExecutorId(String value)
optional string executor_id = 8; |
StoreTypes.TaskData.Builder |
setExecutorIdBytes(com.google.protobuf.ByteString value)
optional string executor_id = 8; |
StoreTypes.TaskData.Builder |
setField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
StoreTypes.TaskData.Builder |
setGettingResultTime(long value)
int64 getting_result_time = 18; |
StoreTypes.TaskData.Builder |
setHost(String value)
optional string host = 9; |
StoreTypes.TaskData.Builder |
setHostBytes(com.google.protobuf.ByteString value)
optional string host = 9; |
StoreTypes.TaskData.Builder |
setIndex(int value)
int32 index = 2; |
StoreTypes.TaskData.Builder |
setLaunchTime(long value)
int64 launch_time = 5; |
StoreTypes.TaskData.Builder |
setPartitionId(int value)
int32 partition_id = 4; |
StoreTypes.TaskData.Builder |
setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
Object value) |
StoreTypes.TaskData.Builder |
setResultFetchStart(long value)
optional int64 result_fetch_start = 6; |
StoreTypes.TaskData.Builder |
setSchedulerDelay(long value)
int64 scheduler_delay = 17; |
StoreTypes.TaskData.Builder |
setSpeculative(boolean value)
bool speculative = 12; |
StoreTypes.TaskData.Builder |
setStatus(String value)
optional string status = 10; |
StoreTypes.TaskData.Builder |
setStatusBytes(com.google.protobuf.ByteString value)
optional string status = 10; |
StoreTypes.TaskData.Builder |
setTaskId(long value)
int64 task_id = 1; |
StoreTypes.TaskData.Builder |
setTaskLocality(String value)
optional string task_locality = 11; |
StoreTypes.TaskData.Builder |
setTaskLocalityBytes(com.google.protobuf.ByteString value)
optional string task_locality = 11; |
StoreTypes.TaskData.Builder |
setTaskMetrics(StoreTypes.TaskMetrics.Builder builderForValue)
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15; |
StoreTypes.TaskData.Builder |
setTaskMetrics(StoreTypes.TaskMetrics value)
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15; |
StoreTypes.TaskData.Builder |
setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newBuilderForField
findInitializationErrors, getInitializationErrorString, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toString
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public StoreTypes.TaskData.Builder clear()
clear
in interface com.google.protobuf.Message.Builder
clear
in interface com.google.protobuf.MessageLite.Builder
clear
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskData.Builder>
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
getDescriptorForType
in interface com.google.protobuf.Message.Builder
getDescriptorForType
in interface com.google.protobuf.MessageOrBuilder
getDescriptorForType
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskData.Builder>
public StoreTypes.TaskData getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
public StoreTypes.TaskData build()
build
in interface com.google.protobuf.Message.Builder
build
in interface com.google.protobuf.MessageLite.Builder
public StoreTypes.TaskData buildPartial()
buildPartial
in interface com.google.protobuf.Message.Builder
buildPartial
in interface com.google.protobuf.MessageLite.Builder
public StoreTypes.TaskData.Builder clone()
clone
in interface com.google.protobuf.Message.Builder
clone
in interface com.google.protobuf.MessageLite.Builder
clone
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskData.Builder>
public StoreTypes.TaskData.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
setField
in interface com.google.protobuf.Message.Builder
setField
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskData.Builder>
public StoreTypes.TaskData.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
clearField
in interface com.google.protobuf.Message.Builder
clearField
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskData.Builder>
public StoreTypes.TaskData.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
clearOneof
in interface com.google.protobuf.Message.Builder
clearOneof
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskData.Builder>
public StoreTypes.TaskData.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
setRepeatedField
in interface com.google.protobuf.Message.Builder
setRepeatedField
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskData.Builder>
public StoreTypes.TaskData.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
addRepeatedField
in interface com.google.protobuf.Message.Builder
addRepeatedField
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskData.Builder>
public StoreTypes.TaskData.Builder mergeFrom(com.google.protobuf.Message other)
mergeFrom
in interface com.google.protobuf.Message.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.TaskData.Builder>
public StoreTypes.TaskData.Builder mergeFrom(StoreTypes.TaskData other)
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskData.Builder>
public StoreTypes.TaskData.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
mergeFrom
in interface com.google.protobuf.Message.Builder
mergeFrom
in interface com.google.protobuf.MessageLite.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.TaskData.Builder>
java.io.IOException
public long getTaskId()
int64 task_id = 1;
getTaskId
in interface StoreTypes.TaskDataOrBuilder
public StoreTypes.TaskData.Builder setTaskId(long value)
int64 task_id = 1;
value
- The taskId to set.public StoreTypes.TaskData.Builder clearTaskId()
int64 task_id = 1;
public int getIndex()
int32 index = 2;
getIndex
in interface StoreTypes.TaskDataOrBuilder
public StoreTypes.TaskData.Builder setIndex(int value)
int32 index = 2;
value
- The index to set.public StoreTypes.TaskData.Builder clearIndex()
int32 index = 2;
public int getAttempt()
int32 attempt = 3;
getAttempt
in interface StoreTypes.TaskDataOrBuilder
public StoreTypes.TaskData.Builder setAttempt(int value)
int32 attempt = 3;
value
- The attempt to set.public StoreTypes.TaskData.Builder clearAttempt()
int32 attempt = 3;
public int getPartitionId()
int32 partition_id = 4;
getPartitionId
in interface StoreTypes.TaskDataOrBuilder
public StoreTypes.TaskData.Builder setPartitionId(int value)
int32 partition_id = 4;
value
- The partitionId to set.public StoreTypes.TaskData.Builder clearPartitionId()
int32 partition_id = 4;
public long getLaunchTime()
int64 launch_time = 5;
getLaunchTime
in interface StoreTypes.TaskDataOrBuilder
public StoreTypes.TaskData.Builder setLaunchTime(long value)
int64 launch_time = 5;
value
- The launchTime to set.public StoreTypes.TaskData.Builder clearLaunchTime()
int64 launch_time = 5;
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 StoreTypes.TaskData.Builder setResultFetchStart(long value)
optional int64 result_fetch_start = 6;
value
- The resultFetchStart to set.public StoreTypes.TaskData.Builder clearResultFetchStart()
optional int64 result_fetch_start = 6;
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 StoreTypes.TaskData.Builder setDuration(long value)
optional int64 duration = 7;
value
- The duration to set.public StoreTypes.TaskData.Builder clearDuration()
optional int64 duration = 7;
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 StoreTypes.TaskData.Builder setExecutorId(String value)
optional string executor_id = 8;
value
- The executorId to set.public StoreTypes.TaskData.Builder clearExecutorId()
optional string executor_id = 8;
public StoreTypes.TaskData.Builder setExecutorIdBytes(com.google.protobuf.ByteString value)
optional string executor_id = 8;
value
- The bytes for executorId to set.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 StoreTypes.TaskData.Builder setHost(String value)
optional string host = 9;
value
- The host to set.public StoreTypes.TaskData.Builder clearHost()
optional string host = 9;
public StoreTypes.TaskData.Builder setHostBytes(com.google.protobuf.ByteString value)
optional string host = 9;
value
- The bytes for host to set.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 StoreTypes.TaskData.Builder setStatus(String value)
optional string status = 10;
value
- The status to set.public StoreTypes.TaskData.Builder clearStatus()
optional string status = 10;
public StoreTypes.TaskData.Builder setStatusBytes(com.google.protobuf.ByteString value)
optional string status = 10;
value
- The bytes for status to set.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 StoreTypes.TaskData.Builder setTaskLocality(String value)
optional string task_locality = 11;
value
- The taskLocality to set.public StoreTypes.TaskData.Builder clearTaskLocality()
optional string task_locality = 11;
public StoreTypes.TaskData.Builder setTaskLocalityBytes(com.google.protobuf.ByteString value)
optional string task_locality = 11;
value
- The bytes for taskLocality to set.public boolean getSpeculative()
bool speculative = 12;
getSpeculative
in interface StoreTypes.TaskDataOrBuilder
public StoreTypes.TaskData.Builder setSpeculative(boolean value)
bool speculative = 12;
value
- The speculative to set.public StoreTypes.TaskData.Builder clearSpeculative()
bool speculative = 12;
public java.util.List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
getAccumulatorUpdatesList
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.TaskData.Builder setAccumulatorUpdates(int index, StoreTypes.AccumulableInfo value)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
public StoreTypes.TaskData.Builder setAccumulatorUpdates(int index, StoreTypes.AccumulableInfo.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
public StoreTypes.TaskData.Builder addAccumulatorUpdates(StoreTypes.AccumulableInfo value)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
public StoreTypes.TaskData.Builder addAccumulatorUpdates(int index, StoreTypes.AccumulableInfo value)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
public StoreTypes.TaskData.Builder addAccumulatorUpdates(StoreTypes.AccumulableInfo.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
public StoreTypes.TaskData.Builder addAccumulatorUpdates(int index, StoreTypes.AccumulableInfo.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
public StoreTypes.TaskData.Builder addAllAccumulatorUpdates(Iterable<? extends StoreTypes.AccumulableInfo> values)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
public StoreTypes.TaskData.Builder clearAccumulatorUpdates()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
public StoreTypes.TaskData.Builder removeAccumulatorUpdates(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
public StoreTypes.AccumulableInfo.Builder getAccumulatorUpdatesBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
public StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
getAccumulatorUpdatesOrBuilder
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 StoreTypes.AccumulableInfo.Builder addAccumulatorUpdatesBuilder()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
public StoreTypes.AccumulableInfo.Builder addAccumulatorUpdatesBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
public java.util.List<StoreTypes.AccumulableInfo.Builder> getAccumulatorUpdatesBuilderList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
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 StoreTypes.TaskData.Builder setErrorMessage(String value)
optional string error_message = 14;
value
- The errorMessage to set.public StoreTypes.TaskData.Builder clearErrorMessage()
optional string error_message = 14;
public StoreTypes.TaskData.Builder setErrorMessageBytes(com.google.protobuf.ByteString value)
optional string error_message = 14;
value
- The bytes for errorMessage to set.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.TaskData.Builder setTaskMetrics(StoreTypes.TaskMetrics value)
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
public StoreTypes.TaskData.Builder setTaskMetrics(StoreTypes.TaskMetrics.Builder builderForValue)
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
public StoreTypes.TaskData.Builder mergeTaskMetrics(StoreTypes.TaskMetrics value)
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
public StoreTypes.TaskData.Builder clearTaskMetrics()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
public StoreTypes.TaskMetrics.Builder getTaskMetricsBuilder()
optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
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 StoreTypes.TaskData.Builder clearExecutorLogs()
public StoreTypes.TaskData.Builder removeExecutorLogs(String key)
map<string, string> executor_logs = 16;
@Deprecated public java.util.Map<String,String> getMutableExecutorLogs()
public StoreTypes.TaskData.Builder putExecutorLogs(String key, String value)
map<string, string> executor_logs = 16;
public StoreTypes.TaskData.Builder putAllExecutorLogs(java.util.Map<String,String> values)
map<string, string> executor_logs = 16;
public long getSchedulerDelay()
int64 scheduler_delay = 17;
getSchedulerDelay
in interface StoreTypes.TaskDataOrBuilder
public StoreTypes.TaskData.Builder setSchedulerDelay(long value)
int64 scheduler_delay = 17;
value
- The schedulerDelay to set.public StoreTypes.TaskData.Builder clearSchedulerDelay()
int64 scheduler_delay = 17;
public long getGettingResultTime()
int64 getting_result_time = 18;
getGettingResultTime
in interface StoreTypes.TaskDataOrBuilder
public StoreTypes.TaskData.Builder setGettingResultTime(long value)
int64 getting_result_time = 18;
value
- The gettingResultTime to set.public StoreTypes.TaskData.Builder clearGettingResultTime()
int64 getting_result_time = 18;
public final StoreTypes.TaskData.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
setUnknownFields
in interface com.google.protobuf.Message.Builder
setUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskData.Builder>
public final StoreTypes.TaskData.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
mergeUnknownFields
in interface com.google.protobuf.Message.Builder
mergeUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskData.Builder>