Package org.apache.spark.status.protobuf

Class StoreTypes.CachedQuantile

Object

com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessage

org.apache.spark.status.protobuf.StoreTypes.CachedQuantile

All Implemented Interfaces:

com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Serializable, StoreTypes.CachedQuantileOrBuilder

Enclosing class:

StoreTypes

public static final class StoreTypes.CachedQuantile
extends com.google.protobuf.GeneratedMessage
implements StoreTypes.CachedQuantileOrBuilder

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

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	StoreTypes.CachedQuantile.Builder	Protobuf type org.apache.spark.status.protobuf.CachedQuantile

Nested 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

Fields

Modifier and Type	Field	Description
static final int	BYTES_READ_FIELD_NUMBER
static final int	BYTES_WRITTEN_FIELD_NUMBER
static final int	DISK_BYTES_SPILLED_FIELD_NUMBER
static final int	DURATION_FIELD_NUMBER
static final int	EXECUTOR_CPU_TIME_FIELD_NUMBER
static final int	EXECUTOR_DESERIALIZE_CPU_TIME_FIELD_NUMBER
static final int	EXECUTOR_DESERIALIZE_TIME_FIELD_NUMBER
static final int	EXECUTOR_RUN_TIME_FIELD_NUMBER
static final int	GETTING_RESULT_TIME_FIELD_NUMBER
static final int	JVM_GC_TIME_FIELD_NUMBER
static final int	MEMORY_BYTES_SPILLED_FIELD_NUMBER
static final int	PEAK_EXECUTION_MEMORY_FIELD_NUMBER
static final int	QUANTILE_FIELD_NUMBER
static final int	RECORDS_READ_FIELD_NUMBER
static final int	RECORDS_WRITTEN_FIELD_NUMBER
static final int	RESULT_SERIALIZATION_TIME_FIELD_NUMBER
static final int	RESULT_SIZE_FIELD_NUMBER
static final int	SCHEDULER_DELAY_FIELD_NUMBER
static final int	SHUFFLE_CORRUPT_MERGED_BLOCK_CHUNKS_FIELD_NUMBER
static final int	SHUFFLE_FETCH_WAIT_TIME_FIELD_NUMBER
static final int	SHUFFLE_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_MERGED_FETCH_FALLBACK_COUNT_FIELD_NUMBER
static final int	SHUFFLE_MERGED_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_MERGED_LOCAL_BYTES_READ_FIELD_NUMBER
static final int	SHUFFLE_MERGED_LOCAL_CHUNKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_MERGED_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_MERGED_REMOTE_BYTES_READ_FIELD_NUMBER
static final int	SHUFFLE_MERGED_REMOTE_CHUNKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_MERGED_REMOTE_REQS_DURATION_FIELD_NUMBER
static final int	SHUFFLE_READ_BYTES_FIELD_NUMBER
static final int	SHUFFLE_RECORDS_READ_FIELD_NUMBER
static final int	SHUFFLE_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_REMOTE_BYTES_READ_FIELD_NUMBER
static final int	SHUFFLE_REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER
static final int	SHUFFLE_REMOTE_REQS_DURATION_FIELD_NUMBER
static final int	SHUFFLE_TOTAL_BLOCKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_WRITE_BYTES_FIELD_NUMBER
static final int	SHUFFLE_WRITE_RECORDS_FIELD_NUMBER
static final int	SHUFFLE_WRITE_TIME_FIELD_NUMBER
static final int	STAGE_ATTEMPT_ID_FIELD_NUMBER
static final int	STAGE_ID_FIELD_NUMBER
static final int	TASK_COUNT_FIELD_NUMBER

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
double	getBytesRead()	double bytes_read = 18;
double	getBytesWritten()	double bytes_written = 20;
static StoreTypes.CachedQuantile	getDefaultInstance()
StoreTypes.CachedQuantile	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
double	getDiskBytesSpilled()	double disk_bytes_spilled = 17;
double	getDuration()	double duration = 5;
double	getExecutorCpuTime()	double executor_cpu_time = 9;
double	getExecutorDeserializeCpuTime()	double executor_deserialize_cpu_time = 7;
double	getExecutorDeserializeTime()	double executor_deserialize_time = 6;
double	getExecutorRunTime()	double executor_run_time = 8;
double	getGettingResultTime()	double getting_result_time = 13;
double	getJvmGcTime()	double jvm_gc_time = 11;
double	getMemoryBytesSpilled()	double memory_bytes_spilled = 16;
com.google.protobuf.Parser<StoreTypes.CachedQuantile>	getParserForType()
double	getPeakExecutionMemory()	double peak_execution_memory = 15;
String	getQuantile()	optional string quantile = 3;
com.google.protobuf.ByteString	getQuantileBytes()	optional string quantile = 3;
double	getRecordsRead()	double records_read = 19;
double	getRecordsWritten()	double records_written = 21;
double	getResultSerializationTime()	double result_serialization_time = 12;
double	getResultSize()	double result_size = 10;
double	getSchedulerDelay()	double scheduler_delay = 14;
int	getSerializedSize()
double	getShuffleCorruptMergedBlockChunks()	double shuffle_corrupt_merged_block_chunks = 33;
double	getShuffleFetchWaitTime()	double shuffle_fetch_wait_time = 26;
double	getShuffleLocalBlocksFetched()	double shuffle_local_blocks_fetched = 25;
double	getShuffleMergedFetchFallbackCount()	double shuffle_merged_fetch_fallback_count = 34;
double	getShuffleMergedLocalBlocksFetched()	double shuffle_merged_local_blocks_fetched = 36;
double	getShuffleMergedLocalBytesRead()	double shuffle_merged_local_bytes_read = 40;
double	getShuffleMergedLocalChunksFetched()	double shuffle_merged_local_chunks_fetched = 38;
double	getShuffleMergedRemoteBlocksFetched()	double shuffle_merged_remote_blocks_fetched = 35;
double	getShuffleMergedRemoteBytesRead()	double shuffle_merged_remote_bytes_read = 39;
double	getShuffleMergedRemoteChunksFetched()	double shuffle_merged_remote_chunks_fetched = 37;
double	getShuffleMergedRemoteReqsDuration()	double shuffle_merged_remote_reqs_duration = 42;
double	getShuffleReadBytes()	double shuffle_read_bytes = 22;
double	getShuffleRecordsRead()	double shuffle_records_read = 23;
double	getShuffleRemoteBlocksFetched()	double shuffle_remote_blocks_fetched = 24;
double	getShuffleRemoteBytesRead()	double shuffle_remote_bytes_read = 27;
double	getShuffleRemoteBytesReadToDisk()	double shuffle_remote_bytes_read_to_disk = 28;
double	getShuffleRemoteReqsDuration()	double shuffle_remote_reqs_duration = 41;
double	getShuffleTotalBlocksFetched()	double shuffle_total_blocks_fetched = 29;
double	getShuffleWriteBytes()	double shuffle_write_bytes = 30;
double	getShuffleWriteRecords()	double shuffle_write_records = 31;
double	getShuffleWriteTime()	double shuffle_write_time = 32;
int	getStageAttemptId()	int32 stage_attempt_id = 2;
long	getStageId()	int64 stage_id = 1;
long	getTaskCount()	int64 task_count = 4;
int	hashCode()
boolean	hasQuantile()	optional string quantile = 3;
final boolean	isInitialized()
static StoreTypes.CachedQuantile.Builder	newBuilder()
static StoreTypes.CachedQuantile.Builder	newBuilder(StoreTypes.CachedQuantile prototype)
StoreTypes.CachedQuantile.Builder	newBuilderForType()
static StoreTypes.CachedQuantile	parseDelimitedFrom(InputStream input)
static StoreTypes.CachedQuantile	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.CachedQuantile	parseFrom(byte[] data)
static StoreTypes.CachedQuantile	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.CachedQuantile	parseFrom(com.google.protobuf.ByteString data)
static StoreTypes.CachedQuantile	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.CachedQuantile	parseFrom(com.google.protobuf.CodedInputStream input)
static StoreTypes.CachedQuantile	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.CachedQuantile	parseFrom(InputStream input)
static StoreTypes.CachedQuantile	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.CachedQuantile	parseFrom(ByteBuffer data)
static StoreTypes.CachedQuantile	parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<StoreTypes.CachedQuantile>	parser()
StoreTypes.CachedQuantile.Builder	toBuilder()
void	writeTo(com.google.protobuf.CodedOutputStream output)

Methods inherited from class com.google.protobuf.GeneratedMessage

getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newFileScopedGeneratedExtension, newMessageScopedGeneratedExtension

Methods inherited from class com.google.protobuf.AbstractMessage

findInitializationErrors, getInitializationErrorString, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from interface com.google.protobuf.MessageOrBuilder

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

Field Details

STAGE_ID_FIELD_NUMBER

public static final int STAGE_ID_FIELD_NUMBER

See Also:

• Constant Field Values

STAGE_ATTEMPT_ID_FIELD_NUMBER

public static final int STAGE_ATTEMPT_ID_FIELD_NUMBER

See Also:

• Constant Field Values

QUANTILE_FIELD_NUMBER

public static final int QUANTILE_FIELD_NUMBER

See Also:

• Constant Field Values

TASK_COUNT_FIELD_NUMBER

public static final int TASK_COUNT_FIELD_NUMBER

See Also:

• Constant Field Values

DURATION_FIELD_NUMBER

public static final int DURATION_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_DESERIALIZE_TIME_FIELD_NUMBER

public static final int EXECUTOR_DESERIALIZE_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_DESERIALIZE_CPU_TIME_FIELD_NUMBER

public static final int EXECUTOR_DESERIALIZE_CPU_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_RUN_TIME_FIELD_NUMBER

public static final int EXECUTOR_RUN_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_CPU_TIME_FIELD_NUMBER

public static final int EXECUTOR_CPU_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

RESULT_SIZE_FIELD_NUMBER

public static final int RESULT_SIZE_FIELD_NUMBER

See Also:

• Constant Field Values

JVM_GC_TIME_FIELD_NUMBER

public static final int JVM_GC_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

RESULT_SERIALIZATION_TIME_FIELD_NUMBER

public static final int RESULT_SERIALIZATION_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

GETTING_RESULT_TIME_FIELD_NUMBER

public static final int GETTING_RESULT_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

SCHEDULER_DELAY_FIELD_NUMBER

public static final int SCHEDULER_DELAY_FIELD_NUMBER

See Also:

• Constant Field Values

PEAK_EXECUTION_MEMORY_FIELD_NUMBER

public static final int PEAK_EXECUTION_MEMORY_FIELD_NUMBER

See Also:

• Constant Field Values

MEMORY_BYTES_SPILLED_FIELD_NUMBER

public static final int MEMORY_BYTES_SPILLED_FIELD_NUMBER

See Also:

• Constant Field Values

DISK_BYTES_SPILLED_FIELD_NUMBER

public static final int DISK_BYTES_SPILLED_FIELD_NUMBER

See Also:

• Constant Field Values

BYTES_READ_FIELD_NUMBER

public static final int BYTES_READ_FIELD_NUMBER

See Also:

• Constant Field Values

RECORDS_READ_FIELD_NUMBER

public static final int RECORDS_READ_FIELD_NUMBER

See Also:

• Constant Field Values

BYTES_WRITTEN_FIELD_NUMBER

public static final int BYTES_WRITTEN_FIELD_NUMBER

See Also:

• Constant Field Values

RECORDS_WRITTEN_FIELD_NUMBER

public static final int RECORDS_WRITTEN_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_READ_BYTES_FIELD_NUMBER

public static final int SHUFFLE_READ_BYTES_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_RECORDS_READ_FIELD_NUMBER

public static final int SHUFFLE_RECORDS_READ_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_FETCH_WAIT_TIME_FIELD_NUMBER

public static final int SHUFFLE_FETCH_WAIT_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_REMOTE_BYTES_READ_FIELD_NUMBER

public static final int SHUFFLE_REMOTE_BYTES_READ_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER

public static final int SHUFFLE_REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_TOTAL_BLOCKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_TOTAL_BLOCKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_WRITE_BYTES_FIELD_NUMBER

public static final int SHUFFLE_WRITE_BYTES_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_WRITE_RECORDS_FIELD_NUMBER

public static final int SHUFFLE_WRITE_RECORDS_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_WRITE_TIME_FIELD_NUMBER

public static final int SHUFFLE_WRITE_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_CORRUPT_MERGED_BLOCK_CHUNKS_FIELD_NUMBER

public static final int SHUFFLE_CORRUPT_MERGED_BLOCK_CHUNKS_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_FETCH_FALLBACK_COUNT_FIELD_NUMBER

public static final int SHUFFLE_MERGED_FETCH_FALLBACK_COUNT_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_MERGED_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_MERGED_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_REMOTE_CHUNKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_MERGED_REMOTE_CHUNKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_LOCAL_CHUNKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_MERGED_LOCAL_CHUNKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_REMOTE_BYTES_READ_FIELD_NUMBER

public static final int SHUFFLE_MERGED_REMOTE_BYTES_READ_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_LOCAL_BYTES_READ_FIELD_NUMBER

public static final int SHUFFLE_MERGED_LOCAL_BYTES_READ_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_REMOTE_REQS_DURATION_FIELD_NUMBER

public static final int SHUFFLE_REMOTE_REQS_DURATION_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_REMOTE_REQS_DURATION_FIELD_NUMBER

public static final int SHUFFLE_MERGED_REMOTE_REQS_DURATION_FIELD_NUMBER

See Also:

• Constant Field Values

Method Details

getDescriptor

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

getStageId

public long getStageId()

int64 stage_id = 1;

Specified by:

getStageId in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The stageId.

getStageAttemptId

public int getStageAttemptId()

int32 stage_attempt_id = 2;

Specified by:

getStageAttemptId in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The stageAttemptId.

hasQuantile

public boolean hasQuantile()

optional string quantile = 3;

Specified by:

hasQuantile in interface StoreTypes.CachedQuantileOrBuilder

Returns:

Whether the quantile field is set.

getQuantile

public String getQuantile()

optional string quantile = 3;

Specified by:

getQuantile in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The quantile.

getQuantileBytes

public com.google.protobuf.ByteString getQuantileBytes()

optional string quantile = 3;

Specified by:

getQuantileBytes in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The bytes for quantile.

getTaskCount

public long getTaskCount()

int64 task_count = 4;

Specified by:

getTaskCount in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The taskCount.

getDuration

public double getDuration()

double duration = 5;

Specified by:

getDuration in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The duration.

getExecutorDeserializeTime

public double getExecutorDeserializeTime()

double executor_deserialize_time = 6;

Specified by:

getExecutorDeserializeTime in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The executorDeserializeTime.

getExecutorDeserializeCpuTime

public double getExecutorDeserializeCpuTime()

double executor_deserialize_cpu_time = 7;

Specified by:

getExecutorDeserializeCpuTime in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The executorDeserializeCpuTime.

getExecutorRunTime

public double getExecutorRunTime()

double executor_run_time = 8;

Specified by:

getExecutorRunTime in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The executorRunTime.

getExecutorCpuTime

public double getExecutorCpuTime()

double executor_cpu_time = 9;

Specified by:

getExecutorCpuTime in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The executorCpuTime.

getResultSize

public double getResultSize()

double result_size = 10;

Specified by:

getResultSize in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The resultSize.

getJvmGcTime

public double getJvmGcTime()

double jvm_gc_time = 11;

Specified by:

getJvmGcTime in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The jvmGcTime.

getResultSerializationTime

public double getResultSerializationTime()

double result_serialization_time = 12;

Specified by:

getResultSerializationTime in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The resultSerializationTime.

getGettingResultTime

public double getGettingResultTime()

double getting_result_time = 13;

Specified by:

getGettingResultTime in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The gettingResultTime.

getSchedulerDelay

public double getSchedulerDelay()

double scheduler_delay = 14;

Specified by:

getSchedulerDelay in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The schedulerDelay.

getPeakExecutionMemory

public double getPeakExecutionMemory()

double peak_execution_memory = 15;

Specified by:

getPeakExecutionMemory in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The peakExecutionMemory.

getMemoryBytesSpilled

public double getMemoryBytesSpilled()

double memory_bytes_spilled = 16;

Specified by:

getMemoryBytesSpilled in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The memoryBytesSpilled.

getDiskBytesSpilled

public double getDiskBytesSpilled()

double disk_bytes_spilled = 17;

Specified by:

getDiskBytesSpilled in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The diskBytesSpilled.

getBytesRead

public double getBytesRead()

double bytes_read = 18;

Specified by:

getBytesRead in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The bytesRead.

getRecordsRead

public double getRecordsRead()

double records_read = 19;

Specified by:

getRecordsRead in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The recordsRead.

getBytesWritten

public double getBytesWritten()

double bytes_written = 20;

Specified by:

getBytesWritten in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The bytesWritten.

getRecordsWritten

public double getRecordsWritten()

double records_written = 21;

Specified by:

getRecordsWritten in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The recordsWritten.

getShuffleReadBytes

public double getShuffleReadBytes()

double shuffle_read_bytes = 22;

Specified by:

getShuffleReadBytes in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleReadBytes.

getShuffleRecordsRead

public double getShuffleRecordsRead()

double shuffle_records_read = 23;

Specified by:

getShuffleRecordsRead in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleRecordsRead.

getShuffleRemoteBlocksFetched

public double getShuffleRemoteBlocksFetched()

double shuffle_remote_blocks_fetched = 24;

Specified by:

getShuffleRemoteBlocksFetched in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleRemoteBlocksFetched.

getShuffleLocalBlocksFetched

public double getShuffleLocalBlocksFetched()

double shuffle_local_blocks_fetched = 25;

Specified by:

getShuffleLocalBlocksFetched in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleLocalBlocksFetched.

getShuffleFetchWaitTime

public double getShuffleFetchWaitTime()

double shuffle_fetch_wait_time = 26;

Specified by:

getShuffleFetchWaitTime in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleFetchWaitTime.

getShuffleRemoteBytesRead

public double getShuffleRemoteBytesRead()

double shuffle_remote_bytes_read = 27;

Specified by:

getShuffleRemoteBytesRead in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleRemoteBytesRead.

getShuffleRemoteBytesReadToDisk

public double getShuffleRemoteBytesReadToDisk()

double shuffle_remote_bytes_read_to_disk = 28;

Specified by:

getShuffleRemoteBytesReadToDisk in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleRemoteBytesReadToDisk.

getShuffleTotalBlocksFetched

public double getShuffleTotalBlocksFetched()

double shuffle_total_blocks_fetched = 29;

Specified by:

getShuffleTotalBlocksFetched in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleTotalBlocksFetched.

getShuffleWriteBytes

public double getShuffleWriteBytes()

double shuffle_write_bytes = 30;

Specified by:

getShuffleWriteBytes in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleWriteBytes.

getShuffleWriteRecords

public double getShuffleWriteRecords()

double shuffle_write_records = 31;

Specified by:

getShuffleWriteRecords in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleWriteRecords.

getShuffleWriteTime

public double getShuffleWriteTime()

double shuffle_write_time = 32;

Specified by:

getShuffleWriteTime in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleWriteTime.

getShuffleCorruptMergedBlockChunks

public double getShuffleCorruptMergedBlockChunks()

double shuffle_corrupt_merged_block_chunks = 33;

Specified by:

getShuffleCorruptMergedBlockChunks in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleCorruptMergedBlockChunks.

getShuffleMergedFetchFallbackCount

public double getShuffleMergedFetchFallbackCount()

double shuffle_merged_fetch_fallback_count = 34;

Specified by:

getShuffleMergedFetchFallbackCount in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleMergedFetchFallbackCount.

getShuffleMergedRemoteBlocksFetched

public double getShuffleMergedRemoteBlocksFetched()

double shuffle_merged_remote_blocks_fetched = 35;

Specified by:

getShuffleMergedRemoteBlocksFetched in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleMergedRemoteBlocksFetched.

getShuffleMergedLocalBlocksFetched

public double getShuffleMergedLocalBlocksFetched()

double shuffle_merged_local_blocks_fetched = 36;

Specified by:

getShuffleMergedLocalBlocksFetched in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleMergedLocalBlocksFetched.

getShuffleMergedRemoteChunksFetched

public double getShuffleMergedRemoteChunksFetched()

double shuffle_merged_remote_chunks_fetched = 37;

Specified by:

getShuffleMergedRemoteChunksFetched in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleMergedRemoteChunksFetched.

getShuffleMergedLocalChunksFetched

public double getShuffleMergedLocalChunksFetched()

double shuffle_merged_local_chunks_fetched = 38;

Specified by:

getShuffleMergedLocalChunksFetched in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleMergedLocalChunksFetched.

getShuffleMergedRemoteBytesRead

public double getShuffleMergedRemoteBytesRead()

double shuffle_merged_remote_bytes_read = 39;

Specified by:

getShuffleMergedRemoteBytesRead in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleMergedRemoteBytesRead.

getShuffleMergedLocalBytesRead

public double getShuffleMergedLocalBytesRead()

double shuffle_merged_local_bytes_read = 40;

Specified by:

getShuffleMergedLocalBytesRead in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleMergedLocalBytesRead.

getShuffleRemoteReqsDuration

public double getShuffleRemoteReqsDuration()

double shuffle_remote_reqs_duration = 41;

Specified by:

getShuffleRemoteReqsDuration in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleRemoteReqsDuration.

getShuffleMergedRemoteReqsDuration

public double getShuffleMergedRemoteReqsDuration()

double shuffle_merged_remote_reqs_duration = 42;

Specified by:

getShuffleMergedRemoteReqsDuration in interface StoreTypes.CachedQuantileOrBuilder

Returns:

The shuffleMergedRemoteReqsDuration.

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage

writeTo

public void writeTo(com.google.protobuf.CodedOutputStream output)
             throws IOException

Specified by:

writeTo in interface com.google.protobuf.MessageLite

Overrides:

writeTo in class com.google.protobuf.GeneratedMessage

Throws:

IOException

getSerializedSize

public int getSerializedSize()

Specified by:

getSerializedSize in interface com.google.protobuf.MessageLite

Overrides:

getSerializedSize in class com.google.protobuf.GeneratedMessage

equals

public boolean equals(Object obj)

Specified by:

equals in interface com.google.protobuf.Message

Overrides:

equals in class com.google.protobuf.AbstractMessage

hashCode

public int hashCode()

Specified by:

hashCode in interface com.google.protobuf.Message

Overrides:

hashCode in class com.google.protobuf.AbstractMessage

parseFrom

public static StoreTypes.CachedQuantile parseFrom(ByteBuffer data)
                                           throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.CachedQuantile parseFrom(ByteBuffer data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                           throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.CachedQuantile parseFrom(com.google.protobuf.ByteString data)
                                           throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.CachedQuantile 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.CachedQuantile parseFrom(byte[] data)
                                           throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.CachedQuantile parseFrom(byte[] data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                           throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.CachedQuantile parseFrom(InputStream input)
                                           throws IOException

Throws:

IOException

parseFrom

public static StoreTypes.CachedQuantile parseFrom(InputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                           throws IOException

Throws:

IOException

parseDelimitedFrom

public static StoreTypes.CachedQuantile parseDelimitedFrom(InputStream input)
                                                    throws IOException

Throws:

IOException

parseDelimitedFrom

public static StoreTypes.CachedQuantile parseDelimitedFrom(InputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                    throws IOException

Throws:

IOException

parseFrom

public static StoreTypes.CachedQuantile parseFrom(com.google.protobuf.CodedInputStream input)
                                           throws IOException

Throws:

IOException

parseFrom

public static StoreTypes.CachedQuantile parseFrom(com.google.protobuf.CodedInputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                           throws IOException

Throws:

IOException

newBuilderForType

public StoreTypes.CachedQuantile.Builder newBuilderForType()

Specified by:

newBuilderForType in interface com.google.protobuf.Message

Specified by:

newBuilderForType in interface com.google.protobuf.MessageLite

newBuilder

public static StoreTypes.CachedQuantile.Builder newBuilder()

newBuilder

public static StoreTypes.CachedQuantile.Builder newBuilder(StoreTypes.CachedQuantile prototype)

toBuilder

public StoreTypes.CachedQuantile.Builder toBuilder()

Specified by:

toBuilder in interface com.google.protobuf.Message

Specified by:

toBuilder in interface com.google.protobuf.MessageLite

getDefaultInstance

public static StoreTypes.CachedQuantile getDefaultInstance()

parser

public static com.google.protobuf.Parser<StoreTypes.CachedQuantile> parser()

getParserForType

public com.google.protobuf.Parser<StoreTypes.CachedQuantile> getParserForType()

Specified by:

getParserForType in interface com.google.protobuf.Message

Specified by:

getParserForType in interface com.google.protobuf.MessageLite

Overrides:

getParserForType in class com.google.protobuf.GeneratedMessage

getDefaultInstanceForType

public StoreTypes.CachedQuantile getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder