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; |
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, getUnknownFields, hasField, hasOneoffindInitializationErrors, getInitializationErrorString, toStringtoByteArray, toByteString, writeDelimitedTo, writeTopublic 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 static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public long getTaskTime()
int64 task_time = 1;getTaskTime in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic int getFailedTasks()
int32 failed_tasks = 2;getFailedTasks in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic int getSucceededTasks()
int32 succeeded_tasks = 3;getSucceededTasks in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic int getKilledTasks()
int32 killed_tasks = 4;getKilledTasks in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic long getInputBytes()
int64 input_bytes = 5;getInputBytes in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic long getInputRecords()
int64 input_records = 6;getInputRecords in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic long getOutputBytes()
int64 output_bytes = 7;getOutputBytes in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic long getOutputRecords()
int64 output_records = 8;getOutputRecords in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic long getShuffleRead()
int64 shuffle_read = 9;getShuffleRead in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic long getShuffleReadRecords()
int64 shuffle_read_records = 10;getShuffleReadRecords in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic long getShuffleWrite()
int64 shuffle_write = 11;getShuffleWrite in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic long getShuffleWriteRecords()
int64 shuffle_write_records = 12;getShuffleWriteRecords in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic long getMemoryBytesSpilled()
int64 memory_bytes_spilled = 13;getMemoryBytesSpilled in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic long getDiskBytesSpilled()
int64 disk_bytes_spilled = 14;getDiskBytesSpilled in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic boolean getIsBlacklistedForStage()
bool is_blacklisted_for_stage = 15;getIsBlacklistedForStage in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic boolean hasPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;hasPeakMemoryMetrics in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic StoreTypes.ExecutorMetrics getPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;getPeakMemoryMetrics in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic StoreTypes.ExecutorMetricsOrBuilder getPeakMemoryMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;getPeakMemoryMetricsOrBuilder in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic boolean getIsExcludedForStage()
bool is_excluded_for_stage = 17;getIsExcludedForStage in interface StoreTypes.ExecutorStageSummaryOrBuilderpublic final boolean isInitialized()
isInitialized in interface com.google.protobuf.MessageLiteOrBuilderisInitialized in class com.google.protobuf.GeneratedMessageV3public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException
writeTo in interface com.google.protobuf.MessageLitewriteTo in class com.google.protobuf.GeneratedMessageV3java.io.IOExceptionpublic int getSerializedSize()
getSerializedSize in interface com.google.protobuf.MessageLitegetSerializedSize in class com.google.protobuf.GeneratedMessageV3public boolean equals(Object obj)
equals in interface com.google.protobuf.Messageequals in class com.google.protobuf.AbstractMessagepublic int hashCode()
hashCode in interface com.google.protobuf.MessagehashCode in class com.google.protobuf.AbstractMessagepublic static StoreTypes.ExecutorStageSummary parseFrom(java.nio.ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.ExecutorStageSummary parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.ExecutorStageSummary parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.ExecutorStageSummary parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.ExecutorStageSummary parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.ExecutorStageSummary parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.ExecutorStageSummary parseFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.ExecutorStageSummary parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.ExecutorStageSummary parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.ExecutorStageSummary parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.ExecutorStageSummary parseFrom(com.google.protobuf.CodedInputStream input) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.ExecutorStageSummary parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOExceptionpublic StoreTypes.ExecutorStageSummary.Builder newBuilderForType()
newBuilderForType in interface com.google.protobuf.MessagenewBuilderForType in interface com.google.protobuf.MessageLitepublic 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.MessagetoBuilder in interface com.google.protobuf.MessageLitepublic 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.MessagegetParserForType in interface com.google.protobuf.MessageLitegetParserForType in class com.google.protobuf.GeneratedMessageV3public StoreTypes.ExecutorStageSummary getDefaultInstanceForType()
getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuildergetDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder