public static final class StoreTypes.ExecutorStageSummary extends com.google.protobuf.GeneratedMessageV3 implements StoreTypes.ExecutorStageSummaryOrBuilder
org.apache.spark.status.protobuf.ExecutorStageSummary
Modifier and Type | Class and Description |
---|---|
static class |
StoreTypes.ExecutorStageSummary.Builder
Protobuf type
org.apache.spark.status.protobuf.ExecutorStageSummary |
com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
Modifier and Type | Field and Description |
---|---|
static int |
DISK_BYTES_SPILLED_FIELD_NUMBER |
static int |
FAILED_TASKS_FIELD_NUMBER |
static int |
INPUT_BYTES_FIELD_NUMBER |
static int |
INPUT_RECORDS_FIELD_NUMBER |
static int |
IS_BLACKLISTED_FOR_STAGE_FIELD_NUMBER |
static int |
IS_EXCLUDED_FOR_STAGE_FIELD_NUMBER |
static int |
KILLED_TASKS_FIELD_NUMBER |
static int |
MEMORY_BYTES_SPILLED_FIELD_NUMBER |
static int |
OUTPUT_BYTES_FIELD_NUMBER |
static int |
OUTPUT_RECORDS_FIELD_NUMBER |
static int |
PEAK_MEMORY_METRICS_FIELD_NUMBER |
static int |
SHUFFLE_READ_FIELD_NUMBER |
static int |
SHUFFLE_READ_RECORDS_FIELD_NUMBER |
static int |
SHUFFLE_WRITE_FIELD_NUMBER |
static int |
SHUFFLE_WRITE_RECORDS_FIELD_NUMBER |
static int |
SUCCEEDED_TASKS_FIELD_NUMBER |
static int |
TASK_TIME_FIELD_NUMBER |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
static StoreTypes.ExecutorStageSummary |
getDefaultInstance() |
StoreTypes.ExecutorStageSummary |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
long |
getDiskBytesSpilled()
int64 disk_bytes_spilled = 14; |
int |
getFailedTasks()
int32 failed_tasks = 2; |
long |
getInputBytes()
int64 input_bytes = 5; |
long |
getInputRecords()
int64 input_records = 6; |
boolean |
getIsBlacklistedForStage()
bool is_blacklisted_for_stage = 15; |
boolean |
getIsExcludedForStage()
bool is_excluded_for_stage = 17; |
int |
getKilledTasks()
int32 killed_tasks = 4; |
long |
getMemoryBytesSpilled()
int64 memory_bytes_spilled = 13; |
long |
getOutputBytes()
int64 output_bytes = 7; |
long |
getOutputRecords()
int64 output_records = 8; |
com.google.protobuf.Parser<StoreTypes.ExecutorStageSummary> |
getParserForType() |
StoreTypes.ExecutorMetrics |
getPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16; |
StoreTypes.ExecutorMetricsOrBuilder |
getPeakMemoryMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16; |
int |
getSerializedSize() |
long |
getShuffleRead()
int64 shuffle_read = 9; |
long |
getShuffleReadRecords()
int64 shuffle_read_records = 10; |
long |
getShuffleWrite()
int64 shuffle_write = 11; |
long |
getShuffleWriteRecords()
int64 shuffle_write_records = 12; |
int |
getSucceededTasks()
int32 succeeded_tasks = 3; |
long |
getTaskTime()
int64 task_time = 1; |
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
int |
hashCode() |
boolean |
hasPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16; |
boolean |
isInitialized() |
static StoreTypes.ExecutorStageSummary.Builder |
newBuilder() |
static StoreTypes.ExecutorStageSummary.Builder |
newBuilder(StoreTypes.ExecutorStageSummary prototype) |
StoreTypes.ExecutorStageSummary.Builder |
newBuilderForType() |
static StoreTypes.ExecutorStageSummary |
parseDelimitedFrom(java.io.InputStream input) |
static StoreTypes.ExecutorStageSummary |
parseDelimitedFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.ExecutorStageSummary |
parseFrom(byte[] data) |
static StoreTypes.ExecutorStageSummary |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.ExecutorStageSummary |
parseFrom(java.nio.ByteBuffer data) |
static StoreTypes.ExecutorStageSummary |
parseFrom(java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.ExecutorStageSummary |
parseFrom(com.google.protobuf.ByteString data) |
static StoreTypes.ExecutorStageSummary |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.ExecutorStageSummary |
parseFrom(com.google.protobuf.CodedInputStream input) |
static StoreTypes.ExecutorStageSummary |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.ExecutorStageSummary |
parseFrom(java.io.InputStream input) |
static StoreTypes.ExecutorStageSummary |
parseFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<StoreTypes.ExecutorStageSummary> |
parser() |
StoreTypes.ExecutorStageSummary.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof
findInitializationErrors, getInitializationErrorString, toString
toByteArray, toByteString, writeDelimitedTo, writeTo
public static final int TASK_TIME_FIELD_NUMBER
public static final int FAILED_TASKS_FIELD_NUMBER
public static final int SUCCEEDED_TASKS_FIELD_NUMBER
public static final int KILLED_TASKS_FIELD_NUMBER
public static final int INPUT_BYTES_FIELD_NUMBER
public static final int INPUT_RECORDS_FIELD_NUMBER
public static final int OUTPUT_BYTES_FIELD_NUMBER
public static final int OUTPUT_RECORDS_FIELD_NUMBER
public static final int SHUFFLE_READ_FIELD_NUMBER
public static final int SHUFFLE_READ_RECORDS_FIELD_NUMBER
public static final int SHUFFLE_WRITE_FIELD_NUMBER
public static final int SHUFFLE_WRITE_RECORDS_FIELD_NUMBER
public static final int MEMORY_BYTES_SPILLED_FIELD_NUMBER
public static final int DISK_BYTES_SPILLED_FIELD_NUMBER
public static final int IS_BLACKLISTED_FOR_STAGE_FIELD_NUMBER
public static final int PEAK_MEMORY_METRICS_FIELD_NUMBER
public static final int IS_EXCLUDED_FOR_STAGE_FIELD_NUMBER
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
getUnknownFields
in interface com.google.protobuf.MessageOrBuilder
getUnknownFields
in class com.google.protobuf.GeneratedMessageV3
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public long getTaskTime()
int64 task_time = 1;
getTaskTime
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public int getFailedTasks()
int32 failed_tasks = 2;
getFailedTasks
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public int getSucceededTasks()
int32 succeeded_tasks = 3;
getSucceededTasks
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public int getKilledTasks()
int32 killed_tasks = 4;
getKilledTasks
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public long getInputBytes()
int64 input_bytes = 5;
getInputBytes
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public long getInputRecords()
int64 input_records = 6;
getInputRecords
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public long getOutputBytes()
int64 output_bytes = 7;
getOutputBytes
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public long getOutputRecords()
int64 output_records = 8;
getOutputRecords
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public long getShuffleRead()
int64 shuffle_read = 9;
getShuffleRead
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public long getShuffleReadRecords()
int64 shuffle_read_records = 10;
getShuffleReadRecords
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public long getShuffleWrite()
int64 shuffle_write = 11;
getShuffleWrite
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public long getShuffleWriteRecords()
int64 shuffle_write_records = 12;
getShuffleWriteRecords
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public long getMemoryBytesSpilled()
int64 memory_bytes_spilled = 13;
getMemoryBytesSpilled
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public long getDiskBytesSpilled()
int64 disk_bytes_spilled = 14;
getDiskBytesSpilled
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public boolean getIsBlacklistedForStage()
bool is_blacklisted_for_stage = 15;
getIsBlacklistedForStage
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public boolean hasPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;
hasPeakMemoryMetrics
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public StoreTypes.ExecutorMetrics getPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;
getPeakMemoryMetrics
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public StoreTypes.ExecutorMetricsOrBuilder getPeakMemoryMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;
getPeakMemoryMetricsOrBuilder
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public boolean getIsExcludedForStage()
bool is_excluded_for_stage = 17;
getIsExcludedForStage
in interface StoreTypes.ExecutorStageSummaryOrBuilder
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3
public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException
writeTo
in interface com.google.protobuf.MessageLite
writeTo
in class com.google.protobuf.GeneratedMessageV3
java.io.IOException
public int getSerializedSize()
getSerializedSize
in interface com.google.protobuf.MessageLite
getSerializedSize
in class com.google.protobuf.GeneratedMessageV3
public boolean equals(Object obj)
equals
in interface com.google.protobuf.Message
equals
in class com.google.protobuf.AbstractMessage
public int hashCode()
hashCode
in interface com.google.protobuf.Message
hashCode
in class com.google.protobuf.AbstractMessage
public static StoreTypes.ExecutorStageSummary parseFrom(java.nio.ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.ExecutorStageSummary parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.ExecutorStageSummary parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.ExecutorStageSummary parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.ExecutorStageSummary parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.ExecutorStageSummary parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.ExecutorStageSummary parseFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.ExecutorStageSummary parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static StoreTypes.ExecutorStageSummary parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.ExecutorStageSummary parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static StoreTypes.ExecutorStageSummary parseFrom(com.google.protobuf.CodedInputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.ExecutorStageSummary parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public StoreTypes.ExecutorStageSummary.Builder newBuilderForType()
newBuilderForType
in interface com.google.protobuf.Message
newBuilderForType
in interface com.google.protobuf.MessageLite
public static StoreTypes.ExecutorStageSummary.Builder newBuilder()
public static StoreTypes.ExecutorStageSummary.Builder newBuilder(StoreTypes.ExecutorStageSummary prototype)
public StoreTypes.ExecutorStageSummary.Builder toBuilder()
toBuilder
in interface com.google.protobuf.Message
toBuilder
in interface com.google.protobuf.MessageLite
public static StoreTypes.ExecutorStageSummary getDefaultInstance()
public static com.google.protobuf.Parser<StoreTypes.ExecutorStageSummary> parser()
public com.google.protobuf.Parser<StoreTypes.ExecutorStageSummary> getParserForType()
getParserForType
in interface com.google.protobuf.Message
getParserForType
in interface com.google.protobuf.MessageLite
getParserForType
in class com.google.protobuf.GeneratedMessageV3
public StoreTypes.ExecutorStageSummary getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder