Package org.apache.spark.status.protobuf

Class StoreTypes.ShuffleReadMetrics.Builder

Object

com.google.protobuf.AbstractMessageLite.Builder

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

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

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

All Implemented Interfaces:

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

Enclosing class:

StoreTypes.ShuffleReadMetrics

public static final class StoreTypes.ShuffleReadMetrics.Builder
extends com.google.protobuf.GeneratedMessage.Builder<StoreTypes.ShuffleReadMetrics.Builder>
implements StoreTypes.ShuffleReadMetricsOrBuilder

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

Method Summary

Modifier and Type	Method	Description
StoreTypes.ShuffleReadMetrics	build()
StoreTypes.ShuffleReadMetrics	buildPartial()
StoreTypes.ShuffleReadMetrics.Builder	clear()
StoreTypes.ShuffleReadMetrics.Builder	clearFetchWaitTime()	int64 fetch_wait_time = 3;
StoreTypes.ShuffleReadMetrics.Builder	clearLocalBlocksFetched()	int64 local_blocks_fetched = 2;
StoreTypes.ShuffleReadMetrics.Builder	clearLocalBytesRead()	int64 local_bytes_read = 6;
StoreTypes.ShuffleReadMetrics.Builder	clearRecordsRead()	int64 records_read = 7;
StoreTypes.ShuffleReadMetrics.Builder	clearRemoteBlocksFetched()	int64 remote_blocks_fetched = 1;
StoreTypes.ShuffleReadMetrics.Builder	clearRemoteBytesRead()	int64 remote_bytes_read = 4;
StoreTypes.ShuffleReadMetrics.Builder	clearRemoteBytesReadToDisk()	int64 remote_bytes_read_to_disk = 5;
StoreTypes.ShuffleReadMetrics.Builder	clearRemoteReqsDuration()	int64 remote_reqs_duration = 8;
StoreTypes.ShuffleReadMetrics.Builder	clearShufflePushReadMetrics()	.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;
StoreTypes.ShuffleReadMetrics	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
long	getFetchWaitTime()	int64 fetch_wait_time = 3;
long	getLocalBlocksFetched()	int64 local_blocks_fetched = 2;
long	getLocalBytesRead()	int64 local_bytes_read = 6;
long	getRecordsRead()	int64 records_read = 7;
long	getRemoteBlocksFetched()	int64 remote_blocks_fetched = 1;
long	getRemoteBytesRead()	int64 remote_bytes_read = 4;
long	getRemoteBytesReadToDisk()	int64 remote_bytes_read_to_disk = 5;
long	getRemoteReqsDuration()	int64 remote_reqs_duration = 8;
StoreTypes.ShufflePushReadMetrics	getShufflePushReadMetrics()	.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;
StoreTypes.ShufflePushReadMetrics.Builder	getShufflePushReadMetricsBuilder()	.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;
StoreTypes.ShufflePushReadMetricsOrBuilder	getShufflePushReadMetricsOrBuilder()	.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;
boolean	hasShufflePushReadMetrics()	.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;
final boolean	isInitialized()
StoreTypes.ShuffleReadMetrics.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
StoreTypes.ShuffleReadMetrics.Builder	mergeFrom(com.google.protobuf.Message other)
StoreTypes.ShuffleReadMetrics.Builder	mergeFrom(StoreTypes.ShuffleReadMetrics other)
StoreTypes.ShuffleReadMetrics.Builder	mergeShufflePushReadMetrics(StoreTypes.ShufflePushReadMetrics value)	.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;
StoreTypes.ShuffleReadMetrics.Builder	setFetchWaitTime(long value)	int64 fetch_wait_time = 3;
StoreTypes.ShuffleReadMetrics.Builder	setLocalBlocksFetched(long value)	int64 local_blocks_fetched = 2;
StoreTypes.ShuffleReadMetrics.Builder	setLocalBytesRead(long value)	int64 local_bytes_read = 6;
StoreTypes.ShuffleReadMetrics.Builder	setRecordsRead(long value)	int64 records_read = 7;
StoreTypes.ShuffleReadMetrics.Builder	setRemoteBlocksFetched(long value)	int64 remote_blocks_fetched = 1;
StoreTypes.ShuffleReadMetrics.Builder	setRemoteBytesRead(long value)	int64 remote_bytes_read = 4;
StoreTypes.ShuffleReadMetrics.Builder	setRemoteBytesReadToDisk(long value)	int64 remote_bytes_read_to_disk = 5;
StoreTypes.ShuffleReadMetrics.Builder	setRemoteReqsDuration(long value)	int64 remote_reqs_duration = 8;
StoreTypes.ShuffleReadMetrics.Builder	setShufflePushReadMetrics(StoreTypes.ShufflePushReadMetrics value)	.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;
StoreTypes.ShuffleReadMetrics.Builder	setShufflePushReadMetrics(StoreTypes.ShufflePushReadMetrics.Builder builderForValue)	.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;

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.ShuffleReadMetrics.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.ShuffleReadMetrics.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.ShuffleReadMetrics.Builder>

getDefaultInstanceForType

public StoreTypes.ShuffleReadMetrics getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public StoreTypes.ShuffleReadMetrics build()

Specified by:

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

Specified by:

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

buildPartial

public StoreTypes.ShuffleReadMetrics buildPartial()

Specified by:

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

Specified by:

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

mergeFrom

public StoreTypes.ShuffleReadMetrics.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.ShuffleReadMetrics.Builder>

mergeFrom

public StoreTypes.ShuffleReadMetrics.Builder mergeFrom(StoreTypes.ShuffleReadMetrics 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.ShuffleReadMetrics.Builder>

mergeFrom

public StoreTypes.ShuffleReadMetrics.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.ShuffleReadMetrics.Builder>

Throws:

IOException

getRemoteBlocksFetched

public long getRemoteBlocksFetched()

int64 remote_blocks_fetched = 1;

Specified by:

getRemoteBlocksFetched in interface StoreTypes.ShuffleReadMetricsOrBuilder

Returns:

The remoteBlocksFetched.

setRemoteBlocksFetched

public StoreTypes.ShuffleReadMetrics.Builder setRemoteBlocksFetched(long value)

int64 remote_blocks_fetched = 1;

Parameters:

value - The remoteBlocksFetched to set.

Returns:

This builder for chaining.

clearRemoteBlocksFetched

public StoreTypes.ShuffleReadMetrics.Builder clearRemoteBlocksFetched()

int64 remote_blocks_fetched = 1;

Returns:

This builder for chaining.

getLocalBlocksFetched

public long getLocalBlocksFetched()

int64 local_blocks_fetched = 2;

Specified by:

getLocalBlocksFetched in interface StoreTypes.ShuffleReadMetricsOrBuilder

Returns:

The localBlocksFetched.

setLocalBlocksFetched

public StoreTypes.ShuffleReadMetrics.Builder setLocalBlocksFetched(long value)

int64 local_blocks_fetched = 2;

Parameters:

value - The localBlocksFetched to set.

Returns:

This builder for chaining.

clearLocalBlocksFetched

public StoreTypes.ShuffleReadMetrics.Builder clearLocalBlocksFetched()

int64 local_blocks_fetched = 2;

Returns:

This builder for chaining.

getFetchWaitTime

public long getFetchWaitTime()

int64 fetch_wait_time = 3;

Specified by:

getFetchWaitTime in interface StoreTypes.ShuffleReadMetricsOrBuilder

Returns:

The fetchWaitTime.

setFetchWaitTime

public StoreTypes.ShuffleReadMetrics.Builder setFetchWaitTime(long value)

int64 fetch_wait_time = 3;

Parameters:

value - The fetchWaitTime to set.

Returns:

This builder for chaining.

clearFetchWaitTime

public StoreTypes.ShuffleReadMetrics.Builder clearFetchWaitTime()

int64 fetch_wait_time = 3;

Returns:

This builder for chaining.

getRemoteBytesRead

public long getRemoteBytesRead()

int64 remote_bytes_read = 4;

Specified by:

getRemoteBytesRead in interface StoreTypes.ShuffleReadMetricsOrBuilder

Returns:

The remoteBytesRead.

setRemoteBytesRead

public StoreTypes.ShuffleReadMetrics.Builder setRemoteBytesRead(long value)

int64 remote_bytes_read = 4;

Parameters:

value - The remoteBytesRead to set.

Returns:

This builder for chaining.

clearRemoteBytesRead

public StoreTypes.ShuffleReadMetrics.Builder clearRemoteBytesRead()

int64 remote_bytes_read = 4;

Returns:

This builder for chaining.

getRemoteBytesReadToDisk

public long getRemoteBytesReadToDisk()

int64 remote_bytes_read_to_disk = 5;

Specified by:

getRemoteBytesReadToDisk in interface StoreTypes.ShuffleReadMetricsOrBuilder

Returns:

The remoteBytesReadToDisk.

setRemoteBytesReadToDisk

public StoreTypes.ShuffleReadMetrics.Builder setRemoteBytesReadToDisk(long value)

int64 remote_bytes_read_to_disk = 5;

Parameters:

value - The remoteBytesReadToDisk to set.

Returns:

This builder for chaining.

clearRemoteBytesReadToDisk

public StoreTypes.ShuffleReadMetrics.Builder clearRemoteBytesReadToDisk()

int64 remote_bytes_read_to_disk = 5;

Returns:

This builder for chaining.

getLocalBytesRead

public long getLocalBytesRead()

int64 local_bytes_read = 6;

Specified by:

getLocalBytesRead in interface StoreTypes.ShuffleReadMetricsOrBuilder

Returns:

The localBytesRead.

setLocalBytesRead

public StoreTypes.ShuffleReadMetrics.Builder setLocalBytesRead(long value)

int64 local_bytes_read = 6;

Parameters:

value - The localBytesRead to set.

Returns:

This builder for chaining.

clearLocalBytesRead

public StoreTypes.ShuffleReadMetrics.Builder clearLocalBytesRead()

int64 local_bytes_read = 6;

Returns:

This builder for chaining.

getRecordsRead

public long getRecordsRead()

int64 records_read = 7;

Specified by:

getRecordsRead in interface StoreTypes.ShuffleReadMetricsOrBuilder

Returns:

The recordsRead.

setRecordsRead

public StoreTypes.ShuffleReadMetrics.Builder setRecordsRead(long value)

int64 records_read = 7;

Parameters:

value - The recordsRead to set.

Returns:

This builder for chaining.

clearRecordsRead

public StoreTypes.ShuffleReadMetrics.Builder clearRecordsRead()

int64 records_read = 7;

Returns:

This builder for chaining.

getRemoteReqsDuration

public long getRemoteReqsDuration()

int64 remote_reqs_duration = 8;

Specified by:

getRemoteReqsDuration in interface StoreTypes.ShuffleReadMetricsOrBuilder

Returns:

The remoteReqsDuration.

setRemoteReqsDuration

public StoreTypes.ShuffleReadMetrics.Builder setRemoteReqsDuration(long value)

int64 remote_reqs_duration = 8;

Parameters:

value - The remoteReqsDuration to set.

Returns:

This builder for chaining.

clearRemoteReqsDuration

public StoreTypes.ShuffleReadMetrics.Builder clearRemoteReqsDuration()

int64 remote_reqs_duration = 8;

Returns:

This builder for chaining.

hasShufflePushReadMetrics

public boolean hasShufflePushReadMetrics()

.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;

Specified by:

hasShufflePushReadMetrics in interface StoreTypes.ShuffleReadMetricsOrBuilder

Returns:

Whether the shufflePushReadMetrics field is set.

getShufflePushReadMetrics

public StoreTypes.ShufflePushReadMetrics getShufflePushReadMetrics()

.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;

Specified by:

getShufflePushReadMetrics in interface StoreTypes.ShuffleReadMetricsOrBuilder

Returns:

The shufflePushReadMetrics.

setShufflePushReadMetrics

public StoreTypes.ShuffleReadMetrics.Builder setShufflePushReadMetrics(StoreTypes.ShufflePushReadMetrics value)

.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;

setShufflePushReadMetrics

public StoreTypes.ShuffleReadMetrics.Builder setShufflePushReadMetrics(StoreTypes.ShufflePushReadMetrics.Builder builderForValue)

.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;

mergeShufflePushReadMetrics

public StoreTypes.ShuffleReadMetrics.Builder mergeShufflePushReadMetrics(StoreTypes.ShufflePushReadMetrics value)

.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;

clearShufflePushReadMetrics

public StoreTypes.ShuffleReadMetrics.Builder clearShufflePushReadMetrics()

.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;

getShufflePushReadMetricsBuilder

public StoreTypes.ShufflePushReadMetrics.Builder getShufflePushReadMetricsBuilder()

.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;

getShufflePushReadMetricsOrBuilder

public StoreTypes.ShufflePushReadMetricsOrBuilder getShufflePushReadMetricsOrBuilder()

.org.apache.spark.status.protobuf.ShufflePushReadMetrics shuffle_push_read_metrics = 9;

Specified by:

getShufflePushReadMetricsOrBuilder in interface StoreTypes.ShuffleReadMetricsOrBuilder