Package org.apache.spark.status.protobuf

Class StoreTypes.TaskData.Builder

Object

com.google.protobuf.AbstractMessageLite.Builder

com.google.protobuf.AbstractMessage.Builder<BuilderT>

com.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskData.Builder>

org.apache.spark.status.protobuf.StoreTypes.TaskData.Builder

All Implemented Interfaces:

com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable, StoreTypes.TaskDataOrBuilder

Enclosing class:

StoreTypes.TaskData

public static final class StoreTypes.TaskData.Builder
extends com.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskData.Builder>
implements StoreTypes.TaskDataOrBuilder

Protobuf type org.apache.spark.status.protobuf.TaskData

Method Summary

Modifier and Type	Method	Description
StoreTypes.TaskData.Builder	addAccumulatorUpdates(int index, StoreTypes.AccumulableInfo value)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.TaskData.Builder	addAccumulatorUpdates(int index, 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.TaskData.Builder	addAccumulatorUpdates(StoreTypes.AccumulableInfo.Builder builderForValue)	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	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	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	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;
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;
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;
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;
List<? extends StoreTypes.AccumulableInfoOrBuilder>	getAccumulatorUpdatesOrBuilderList()	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
int	getAttempt()	int32 attempt = 3;
StoreTypes.TaskData	getDefaultInstanceForType()
static final 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;
Map<String,String>	getExecutorLogs()	Deprecated.
int	getExecutorLogsCount()	map<string, string> executor_logs = 16;
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;
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;
final 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	putAllExecutorLogs(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 value)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.TaskData.Builder	setAccumulatorUpdates(int index, StoreTypes.AccumulableInfo.Builder builderForValue)	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	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	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 value)	optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
StoreTypes.TaskData.Builder	setTaskMetrics(StoreTypes.TaskMetrics.Builder builderForValue)	optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;

Methods inherited from class com.google.protobuf.GeneratedMessage.Builder

addRepeatedField, clearField, clearOneof, clone, getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, mergeUnknownFields, newBuilderForField, setField, setRepeatedField, setUnknownFields

Methods inherited from class com.google.protobuf.AbstractMessage.Builder

findInitializationErrors, getInitializationErrorString, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder

mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.Message.Builder

mergeDelimitedFrom, mergeDelimitedFrom

Methods inherited from interface com.google.protobuf.MessageLite.Builder

mergeFrom

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Method Details

getDescriptor

public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

clear

public StoreTypes.TaskData.Builder clear()

Specified by:

clear in interface com.google.protobuf.Message.Builder

Specified by:

clear in interface com.google.protobuf.MessageLite.Builder

Overrides:

clear in class com.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskData.Builder>

getDescriptorForType

public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()

Specified by:

getDescriptorForType in interface com.google.protobuf.Message.Builder

Specified by:

getDescriptorForType in interface com.google.protobuf.MessageOrBuilder

Overrides:

getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskData.Builder>

getDefaultInstanceForType

public StoreTypes.TaskData getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public StoreTypes.TaskData build()

Specified by:

build in interface com.google.protobuf.Message.Builder

Specified by:

build in interface com.google.protobuf.MessageLite.Builder

buildPartial

public StoreTypes.TaskData buildPartial()

Specified by:

buildPartial in interface com.google.protobuf.Message.Builder

Specified by:

buildPartial in interface com.google.protobuf.MessageLite.Builder

mergeFrom

public StoreTypes.TaskData.Builder mergeFrom(com.google.protobuf.Message other)

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.TaskData.Builder>

mergeFrom

public StoreTypes.TaskData.Builder mergeFrom(StoreTypes.TaskData other)

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskData.Builder>

mergeFrom

public StoreTypes.TaskData.Builder mergeFrom(com.google.protobuf.CodedInputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                      throws IOException

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Specified by:

mergeFrom in interface com.google.protobuf.MessageLite.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.TaskData.Builder>

Throws:

IOException

getTaskId

public long getTaskId()

int64 task_id = 1;

Specified by:

getTaskId in interface StoreTypes.TaskDataOrBuilder

Returns:

The taskId.

setTaskId

public StoreTypes.TaskData.Builder setTaskId(long value)

int64 task_id = 1;

Parameters:

value - The taskId to set.

Returns:

This builder for chaining.

clearTaskId

public StoreTypes.TaskData.Builder clearTaskId()

int64 task_id = 1;

Returns:

This builder for chaining.

getIndex

public int getIndex()

int32 index = 2;

Specified by:

getIndex in interface StoreTypes.TaskDataOrBuilder

Returns:

The index.

setIndex

public StoreTypes.TaskData.Builder setIndex(int value)

int32 index = 2;

Parameters:

value - The index to set.

Returns:

This builder for chaining.

clearIndex

public StoreTypes.TaskData.Builder clearIndex()

int32 index = 2;

Returns:

This builder for chaining.

getAttempt

public int getAttempt()

int32 attempt = 3;

Specified by:

getAttempt in interface StoreTypes.TaskDataOrBuilder

Returns:

The attempt.

setAttempt

public StoreTypes.TaskData.Builder setAttempt(int value)

int32 attempt = 3;

Parameters:

value - The attempt to set.

Returns:

This builder for chaining.

clearAttempt

public StoreTypes.TaskData.Builder clearAttempt()

int32 attempt = 3;

Returns:

This builder for chaining.

getPartitionId

public int getPartitionId()

int32 partition_id = 4;

Specified by:

getPartitionId in interface StoreTypes.TaskDataOrBuilder

Returns:

The partitionId.

setPartitionId

public StoreTypes.TaskData.Builder setPartitionId(int value)

int32 partition_id = 4;

Parameters:

value - The partitionId to set.

Returns:

This builder for chaining.

clearPartitionId

public StoreTypes.TaskData.Builder clearPartitionId()

int32 partition_id = 4;

Returns:

This builder for chaining.

getLaunchTime

public long getLaunchTime()

int64 launch_time = 5;

Specified by:

getLaunchTime in interface StoreTypes.TaskDataOrBuilder

Returns:

The launchTime.

setLaunchTime

public StoreTypes.TaskData.Builder setLaunchTime(long value)

int64 launch_time = 5;

Parameters:

value - The launchTime to set.

Returns:

This builder for chaining.

clearLaunchTime

public StoreTypes.TaskData.Builder clearLaunchTime()

int64 launch_time = 5;

Returns:

This builder for chaining.

hasResultFetchStart

public boolean hasResultFetchStart()

optional int64 result_fetch_start = 6;

Specified by:

hasResultFetchStart in interface StoreTypes.TaskDataOrBuilder

Returns:

Whether the resultFetchStart field is set.

getResultFetchStart

public long getResultFetchStart()

optional int64 result_fetch_start = 6;

Specified by:

getResultFetchStart in interface StoreTypes.TaskDataOrBuilder

Returns:

The resultFetchStart.

setResultFetchStart

public StoreTypes.TaskData.Builder setResultFetchStart(long value)

optional int64 result_fetch_start = 6;

Parameters:

value - The resultFetchStart to set.

Returns:

This builder for chaining.

clearResultFetchStart

public StoreTypes.TaskData.Builder clearResultFetchStart()

optional int64 result_fetch_start = 6;

Returns:

This builder for chaining.

hasDuration

public boolean hasDuration()

optional int64 duration = 7;

Specified by:

hasDuration in interface StoreTypes.TaskDataOrBuilder

Returns:

Whether the duration field is set.

getDuration

public long getDuration()

optional int64 duration = 7;

Specified by:

getDuration in interface StoreTypes.TaskDataOrBuilder

Returns:

The duration.

setDuration

public StoreTypes.TaskData.Builder setDuration(long value)

optional int64 duration = 7;

Parameters:

value - The duration to set.

Returns:

This builder for chaining.

clearDuration

public StoreTypes.TaskData.Builder clearDuration()

optional int64 duration = 7;

Returns:

This builder for chaining.

hasExecutorId

public boolean hasExecutorId()

optional string executor_id = 8;

Specified by:

hasExecutorId in interface StoreTypes.TaskDataOrBuilder

Returns:

Whether the executorId field is set.

getExecutorId

public String getExecutorId()

optional string executor_id = 8;

Specified by:

getExecutorId in interface StoreTypes.TaskDataOrBuilder

Returns:

The executorId.

getExecutorIdBytes

public com.google.protobuf.ByteString getExecutorIdBytes()

optional string executor_id = 8;

Specified by:

getExecutorIdBytes in interface StoreTypes.TaskDataOrBuilder

Returns:

The bytes for executorId.

setExecutorId

public StoreTypes.TaskData.Builder setExecutorId(String value)

optional string executor_id = 8;

Parameters:

value - The executorId to set.

Returns:

This builder for chaining.

clearExecutorId

public StoreTypes.TaskData.Builder clearExecutorId()

optional string executor_id = 8;

Returns:

This builder for chaining.

setExecutorIdBytes

public StoreTypes.TaskData.Builder setExecutorIdBytes(com.google.protobuf.ByteString value)

optional string executor_id = 8;

Parameters:

value - The bytes for executorId to set.

Returns:

This builder for chaining.

hasHost

public boolean hasHost()

optional string host = 9;

Specified by:

hasHost in interface StoreTypes.TaskDataOrBuilder

Returns:

Whether the host field is set.

getHost

public String getHost()

optional string host = 9;

Specified by:

getHost in interface StoreTypes.TaskDataOrBuilder

Returns:

The host.

getHostBytes

public com.google.protobuf.ByteString getHostBytes()

optional string host = 9;

Specified by:

getHostBytes in interface StoreTypes.TaskDataOrBuilder

Returns:

The bytes for host.

setHost

public StoreTypes.TaskData.Builder setHost(String value)

optional string host = 9;

Parameters:

value - The host to set.

Returns:

This builder for chaining.

clearHost

public StoreTypes.TaskData.Builder clearHost()

optional string host = 9;

Returns:

This builder for chaining.

setHostBytes

public StoreTypes.TaskData.Builder setHostBytes(com.google.protobuf.ByteString value)

optional string host = 9;

Parameters:

value - The bytes for host to set.

Returns:

This builder for chaining.

hasStatus

public boolean hasStatus()

optional string status = 10;

Specified by:

hasStatus in interface StoreTypes.TaskDataOrBuilder

Returns:

Whether the status field is set.

getStatus

public String getStatus()

optional string status = 10;

Specified by:

getStatus in interface StoreTypes.TaskDataOrBuilder

Returns:

The status.

getStatusBytes

public com.google.protobuf.ByteString getStatusBytes()

optional string status = 10;

Specified by:

getStatusBytes in interface StoreTypes.TaskDataOrBuilder

Returns:

The bytes for status.

setStatus

public StoreTypes.TaskData.Builder setStatus(String value)

optional string status = 10;

Parameters:

value - The status to set.

Returns:

This builder for chaining.

clearStatus

public StoreTypes.TaskData.Builder clearStatus()

optional string status = 10;

Returns:

This builder for chaining.

setStatusBytes

public StoreTypes.TaskData.Builder setStatusBytes(com.google.protobuf.ByteString value)

optional string status = 10;

Parameters:

value - The bytes for status to set.

Returns:

This builder for chaining.

hasTaskLocality

public boolean hasTaskLocality()

optional string task_locality = 11;

Specified by:

hasTaskLocality in interface StoreTypes.TaskDataOrBuilder

Returns:

Whether the taskLocality field is set.

getTaskLocality

public String getTaskLocality()

optional string task_locality = 11;

Specified by:

getTaskLocality in interface StoreTypes.TaskDataOrBuilder

Returns:

The taskLocality.

getTaskLocalityBytes

public com.google.protobuf.ByteString getTaskLocalityBytes()

optional string task_locality = 11;

Specified by:

getTaskLocalityBytes in interface StoreTypes.TaskDataOrBuilder

Returns:

The bytes for taskLocality.

setTaskLocality

public StoreTypes.TaskData.Builder setTaskLocality(String value)

optional string task_locality = 11;

Parameters:

value - The taskLocality to set.

Returns:

This builder for chaining.

clearTaskLocality

public StoreTypes.TaskData.Builder clearTaskLocality()

optional string task_locality = 11;

Returns:

This builder for chaining.

setTaskLocalityBytes

public StoreTypes.TaskData.Builder setTaskLocalityBytes(com.google.protobuf.ByteString value)

optional string task_locality = 11;

Parameters:

value - The bytes for taskLocality to set.

Returns:

This builder for chaining.

getSpeculative

public boolean getSpeculative()

bool speculative = 12;

Specified by:

getSpeculative in interface StoreTypes.TaskDataOrBuilder

Returns:

The speculative.

setSpeculative

public StoreTypes.TaskData.Builder setSpeculative(boolean value)

bool speculative = 12;

Parameters:

value - The speculative to set.

Returns:

This builder for chaining.

clearSpeculative

public StoreTypes.TaskData.Builder clearSpeculative()

bool speculative = 12;

Returns:

This builder for chaining.

getAccumulatorUpdatesList

public List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

Specified by:

getAccumulatorUpdatesList in interface StoreTypes.TaskDataOrBuilder

getAccumulatorUpdatesCount

public int getAccumulatorUpdatesCount()

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

Specified by:

getAccumulatorUpdatesCount in interface StoreTypes.TaskDataOrBuilder

getAccumulatorUpdates

public StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

Specified by:

getAccumulatorUpdates in interface StoreTypes.TaskDataOrBuilder

setAccumulatorUpdates

public StoreTypes.TaskData.Builder setAccumulatorUpdates(int index,
 StoreTypes.AccumulableInfo value)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

setAccumulatorUpdates

public StoreTypes.TaskData.Builder setAccumulatorUpdates(int index,
 StoreTypes.AccumulableInfo.Builder builderForValue)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

addAccumulatorUpdates

public StoreTypes.TaskData.Builder addAccumulatorUpdates(StoreTypes.AccumulableInfo value)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

addAccumulatorUpdates

public StoreTypes.TaskData.Builder addAccumulatorUpdates(int index,
 StoreTypes.AccumulableInfo value)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

addAccumulatorUpdates

public StoreTypes.TaskData.Builder addAccumulatorUpdates(StoreTypes.AccumulableInfo.Builder builderForValue)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

addAccumulatorUpdates

public StoreTypes.TaskData.Builder addAccumulatorUpdates(int index,
 StoreTypes.AccumulableInfo.Builder builderForValue)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

addAllAccumulatorUpdates

public StoreTypes.TaskData.Builder addAllAccumulatorUpdates(Iterable<? extends StoreTypes.AccumulableInfo> values)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

clearAccumulatorUpdates

public StoreTypes.TaskData.Builder clearAccumulatorUpdates()

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

removeAccumulatorUpdates

public StoreTypes.TaskData.Builder removeAccumulatorUpdates(int index)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

getAccumulatorUpdatesBuilder

public StoreTypes.AccumulableInfo.Builder getAccumulatorUpdatesBuilder(int index)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

getAccumulatorUpdatesOrBuilder

public StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

Specified by:

getAccumulatorUpdatesOrBuilder in interface StoreTypes.TaskDataOrBuilder

getAccumulatorUpdatesOrBuilderList

public List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

Specified by:

getAccumulatorUpdatesOrBuilderList in interface StoreTypes.TaskDataOrBuilder

addAccumulatorUpdatesBuilder

public StoreTypes.AccumulableInfo.Builder addAccumulatorUpdatesBuilder()

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

addAccumulatorUpdatesBuilder

public StoreTypes.AccumulableInfo.Builder addAccumulatorUpdatesBuilder(int index)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

getAccumulatorUpdatesBuilderList

public List<StoreTypes.AccumulableInfo.Builder> getAccumulatorUpdatesBuilderList()

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

hasErrorMessage

public boolean hasErrorMessage()

optional string error_message = 14;

Specified by:

hasErrorMessage in interface StoreTypes.TaskDataOrBuilder

Returns:

Whether the errorMessage field is set.

getErrorMessage

public String getErrorMessage()

optional string error_message = 14;

Specified by:

getErrorMessage in interface StoreTypes.TaskDataOrBuilder

Returns:

The errorMessage.

getErrorMessageBytes

public com.google.protobuf.ByteString getErrorMessageBytes()

optional string error_message = 14;

Specified by:

getErrorMessageBytes in interface StoreTypes.TaskDataOrBuilder

Returns:

The bytes for errorMessage.

setErrorMessage

public StoreTypes.TaskData.Builder setErrorMessage(String value)

optional string error_message = 14;

Parameters:

value - The errorMessage to set.

Returns:

This builder for chaining.

clearErrorMessage

public StoreTypes.TaskData.Builder clearErrorMessage()

optional string error_message = 14;

Returns:

This builder for chaining.

setErrorMessageBytes

public StoreTypes.TaskData.Builder setErrorMessageBytes(com.google.protobuf.ByteString value)

optional string error_message = 14;

Parameters:

value - The bytes for errorMessage to set.

Returns:

This builder for chaining.

hasTaskMetrics

public boolean hasTaskMetrics()

optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;

Specified by:

hasTaskMetrics in interface StoreTypes.TaskDataOrBuilder

Returns:

Whether the taskMetrics field is set.

getTaskMetrics

public StoreTypes.TaskMetrics getTaskMetrics()

optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;

Specified by:

getTaskMetrics in interface StoreTypes.TaskDataOrBuilder

Returns:

The taskMetrics.

setTaskMetrics

public StoreTypes.TaskData.Builder setTaskMetrics(StoreTypes.TaskMetrics value)

optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;

setTaskMetrics

public StoreTypes.TaskData.Builder setTaskMetrics(StoreTypes.TaskMetrics.Builder builderForValue)

optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;

mergeTaskMetrics

public StoreTypes.TaskData.Builder mergeTaskMetrics(StoreTypes.TaskMetrics value)

optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;

clearTaskMetrics

public StoreTypes.TaskData.Builder clearTaskMetrics()

optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;

getTaskMetricsBuilder

public StoreTypes.TaskMetrics.Builder getTaskMetricsBuilder()

optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;

getTaskMetricsOrBuilder

public StoreTypes.TaskMetricsOrBuilder getTaskMetricsOrBuilder()

optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;

Specified by:

getTaskMetricsOrBuilder in interface StoreTypes.TaskDataOrBuilder

getExecutorLogsCount

public int getExecutorLogsCount()

Description copied from interface: StoreTypes.TaskDataOrBuilder

map<string, string> executor_logs = 16;

Specified by:

getExecutorLogsCount in interface StoreTypes.TaskDataOrBuilder

containsExecutorLogs

public boolean containsExecutorLogs(String key)

map<string, string> executor_logs = 16;

Specified by:

containsExecutorLogs in interface StoreTypes.TaskDataOrBuilder

getExecutorLogs

@Deprecated
public Map<String,String> getExecutorLogs()

Deprecated.

Use getExecutorLogsMap() instead.

Specified by:

getExecutorLogs in interface StoreTypes.TaskDataOrBuilder

getExecutorLogsMap

public Map<String,String> getExecutorLogsMap()

map<string, string> executor_logs = 16;

Specified by:

getExecutorLogsMap in interface StoreTypes.TaskDataOrBuilder

getExecutorLogsOrDefault

public String getExecutorLogsOrDefault(String key,
 String defaultValue)

map<string, string> executor_logs = 16;

Specified by:

getExecutorLogsOrDefault in interface StoreTypes.TaskDataOrBuilder

getExecutorLogsOrThrow

public String getExecutorLogsOrThrow(String key)

map<string, string> executor_logs = 16;

Specified by:

getExecutorLogsOrThrow in interface StoreTypes.TaskDataOrBuilder

clearExecutorLogs

public StoreTypes.TaskData.Builder clearExecutorLogs()

removeExecutorLogs

public StoreTypes.TaskData.Builder removeExecutorLogs(String key)

map<string, string> executor_logs = 16;

getMutableExecutorLogs

@Deprecated
public Map<String,String> getMutableExecutorLogs()

Deprecated.

Use alternate mutation accessors instead.

putExecutorLogs

public StoreTypes.TaskData.Builder putExecutorLogs(String key,
 String value)

map<string, string> executor_logs = 16;

putAllExecutorLogs

public StoreTypes.TaskData.Builder putAllExecutorLogs(Map<String,String> values)

map<string, string> executor_logs = 16;

getSchedulerDelay

public long getSchedulerDelay()

int64 scheduler_delay = 17;

Specified by:

getSchedulerDelay in interface StoreTypes.TaskDataOrBuilder

Returns:

The schedulerDelay.

setSchedulerDelay

public StoreTypes.TaskData.Builder setSchedulerDelay(long value)

int64 scheduler_delay = 17;

Parameters:

value - The schedulerDelay to set.

Returns:

This builder for chaining.

clearSchedulerDelay

public StoreTypes.TaskData.Builder clearSchedulerDelay()

int64 scheduler_delay = 17;

Returns:

This builder for chaining.

getGettingResultTime

public long getGettingResultTime()

int64 getting_result_time = 18;

Specified by:

getGettingResultTime in interface StoreTypes.TaskDataOrBuilder

Returns:

The gettingResultTime.

setGettingResultTime

public StoreTypes.TaskData.Builder setGettingResultTime(long value)

int64 getting_result_time = 18;

Parameters:

value - The gettingResultTime to set.

Returns:

This builder for chaining.

clearGettingResultTime

public StoreTypes.TaskData.Builder clearGettingResultTime()

int64 getting_result_time = 18;

Returns:

This builder for chaining.