public static final class StoreTypes.StateOperatorProgress extends com.google.protobuf.GeneratedMessageV3 implements StoreTypes.StateOperatorProgressOrBuilder
org.apache.spark.status.protobuf.StateOperatorProgress
Modifier and Type | Class and Description |
---|---|
static class |
StoreTypes.StateOperatorProgress.Builder
Protobuf type
org.apache.spark.status.protobuf.StateOperatorProgress |
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 |
ALL_REMOVALS_TIME_MS_FIELD_NUMBER |
static int |
ALL_UPDATES_TIME_MS_FIELD_NUMBER |
static int |
COMMIT_TIME_MS_FIELD_NUMBER |
static int |
CUSTOM_METRICS_FIELD_NUMBER |
static int |
MEMORY_USED_BYTES_FIELD_NUMBER |
static int |
NUM_ROWS_DROPPED_BY_WATERMARK_FIELD_NUMBER |
static int |
NUM_ROWS_REMOVED_FIELD_NUMBER |
static int |
NUM_ROWS_TOTAL_FIELD_NUMBER |
static int |
NUM_ROWS_UPDATED_FIELD_NUMBER |
static int |
NUM_SHUFFLE_PARTITIONS_FIELD_NUMBER |
static int |
NUM_STATE_STORE_INSTANCES_FIELD_NUMBER |
static int |
OPERATOR_NAME_FIELD_NUMBER |
Modifier and Type | Method and Description |
---|---|
boolean |
containsCustomMetrics(String key)
map<string, int64> custom_metrics = 12; |
boolean |
equals(Object obj) |
long |
getAllRemovalsTimeMs()
int64 all_removals_time_ms = 6; |
long |
getAllUpdatesTimeMs()
int64 all_updates_time_ms = 4; |
long |
getCommitTimeMs()
int64 commit_time_ms = 7; |
java.util.Map<String,Long> |
getCustomMetrics()
Deprecated.
|
int |
getCustomMetricsCount()
map<string, int64> custom_metrics = 12; |
java.util.Map<String,Long> |
getCustomMetricsMap()
map<string, int64> custom_metrics = 12; |
long |
getCustomMetricsOrDefault(String key,
long defaultValue)
map<string, int64> custom_metrics = 12; |
long |
getCustomMetricsOrThrow(String key)
map<string, int64> custom_metrics = 12; |
static StoreTypes.StateOperatorProgress |
getDefaultInstance() |
StoreTypes.StateOperatorProgress |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
long |
getMemoryUsedBytes()
int64 memory_used_bytes = 8; |
long |
getNumRowsDroppedByWatermark()
int64 num_rows_dropped_by_watermark = 9; |
long |
getNumRowsRemoved()
int64 num_rows_removed = 5; |
long |
getNumRowsTotal()
int64 num_rows_total = 2; |
long |
getNumRowsUpdated()
int64 num_rows_updated = 3; |
long |
getNumShufflePartitions()
int64 num_shuffle_partitions = 10; |
long |
getNumStateStoreInstances()
int64 num_state_store_instances = 11; |
String |
getOperatorName()
optional string operator_name = 1; |
com.google.protobuf.ByteString |
getOperatorNameBytes()
optional string operator_name = 1; |
com.google.protobuf.Parser<StoreTypes.StateOperatorProgress> |
getParserForType() |
int |
getSerializedSize() |
int |
hashCode() |
boolean |
hasOperatorName()
optional string operator_name = 1; |
boolean |
isInitialized() |
static StoreTypes.StateOperatorProgress.Builder |
newBuilder() |
static StoreTypes.StateOperatorProgress.Builder |
newBuilder(StoreTypes.StateOperatorProgress prototype) |
StoreTypes.StateOperatorProgress.Builder |
newBuilderForType() |
static StoreTypes.StateOperatorProgress |
parseDelimitedFrom(java.io.InputStream input) |
static StoreTypes.StateOperatorProgress |
parseDelimitedFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.StateOperatorProgress |
parseFrom(byte[] data) |
static StoreTypes.StateOperatorProgress |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.StateOperatorProgress |
parseFrom(java.nio.ByteBuffer data) |
static StoreTypes.StateOperatorProgress |
parseFrom(java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.StateOperatorProgress |
parseFrom(com.google.protobuf.ByteString data) |
static StoreTypes.StateOperatorProgress |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.StateOperatorProgress |
parseFrom(com.google.protobuf.CodedInputStream input) |
static StoreTypes.StateOperatorProgress |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.StateOperatorProgress |
parseFrom(java.io.InputStream input) |
static StoreTypes.StateOperatorProgress |
parseFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<StoreTypes.StateOperatorProgress> |
parser() |
StoreTypes.StateOperatorProgress.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
findInitializationErrors, getInitializationErrorString, toString
toByteArray, toByteString, writeDelimitedTo, writeTo
public static final int OPERATOR_NAME_FIELD_NUMBER
public static final int NUM_ROWS_TOTAL_FIELD_NUMBER
public static final int NUM_ROWS_UPDATED_FIELD_NUMBER
public static final int ALL_UPDATES_TIME_MS_FIELD_NUMBER
public static final int NUM_ROWS_REMOVED_FIELD_NUMBER
public static final int ALL_REMOVALS_TIME_MS_FIELD_NUMBER
public static final int COMMIT_TIME_MS_FIELD_NUMBER
public static final int MEMORY_USED_BYTES_FIELD_NUMBER
public static final int NUM_ROWS_DROPPED_BY_WATERMARK_FIELD_NUMBER
public static final int NUM_SHUFFLE_PARTITIONS_FIELD_NUMBER
public static final int NUM_STATE_STORE_INSTANCES_FIELD_NUMBER
public static final int CUSTOM_METRICS_FIELD_NUMBER
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public boolean hasOperatorName()
optional string operator_name = 1;
hasOperatorName
in interface StoreTypes.StateOperatorProgressOrBuilder
public String getOperatorName()
optional string operator_name = 1;
getOperatorName
in interface StoreTypes.StateOperatorProgressOrBuilder
public com.google.protobuf.ByteString getOperatorNameBytes()
optional string operator_name = 1;
getOperatorNameBytes
in interface StoreTypes.StateOperatorProgressOrBuilder
public long getNumRowsTotal()
int64 num_rows_total = 2;
getNumRowsTotal
in interface StoreTypes.StateOperatorProgressOrBuilder
public long getNumRowsUpdated()
int64 num_rows_updated = 3;
getNumRowsUpdated
in interface StoreTypes.StateOperatorProgressOrBuilder
public long getAllUpdatesTimeMs()
int64 all_updates_time_ms = 4;
getAllUpdatesTimeMs
in interface StoreTypes.StateOperatorProgressOrBuilder
public long getNumRowsRemoved()
int64 num_rows_removed = 5;
getNumRowsRemoved
in interface StoreTypes.StateOperatorProgressOrBuilder
public long getAllRemovalsTimeMs()
int64 all_removals_time_ms = 6;
getAllRemovalsTimeMs
in interface StoreTypes.StateOperatorProgressOrBuilder
public long getCommitTimeMs()
int64 commit_time_ms = 7;
getCommitTimeMs
in interface StoreTypes.StateOperatorProgressOrBuilder
public long getMemoryUsedBytes()
int64 memory_used_bytes = 8;
getMemoryUsedBytes
in interface StoreTypes.StateOperatorProgressOrBuilder
public long getNumRowsDroppedByWatermark()
int64 num_rows_dropped_by_watermark = 9;
getNumRowsDroppedByWatermark
in interface StoreTypes.StateOperatorProgressOrBuilder
public long getNumShufflePartitions()
int64 num_shuffle_partitions = 10;
getNumShufflePartitions
in interface StoreTypes.StateOperatorProgressOrBuilder
public long getNumStateStoreInstances()
int64 num_state_store_instances = 11;
getNumStateStoreInstances
in interface StoreTypes.StateOperatorProgressOrBuilder
public int getCustomMetricsCount()
StoreTypes.StateOperatorProgressOrBuilder
map<string, int64> custom_metrics = 12;
getCustomMetricsCount
in interface StoreTypes.StateOperatorProgressOrBuilder
public boolean containsCustomMetrics(String key)
map<string, int64> custom_metrics = 12;
containsCustomMetrics
in interface StoreTypes.StateOperatorProgressOrBuilder
@Deprecated public java.util.Map<String,Long> getCustomMetrics()
getCustomMetricsMap()
instead.getCustomMetrics
in interface StoreTypes.StateOperatorProgressOrBuilder
public java.util.Map<String,Long> getCustomMetricsMap()
map<string, int64> custom_metrics = 12;
getCustomMetricsMap
in interface StoreTypes.StateOperatorProgressOrBuilder
public long getCustomMetricsOrDefault(String key, long defaultValue)
map<string, int64> custom_metrics = 12;
getCustomMetricsOrDefault
in interface StoreTypes.StateOperatorProgressOrBuilder
public long getCustomMetricsOrThrow(String key)
map<string, int64> custom_metrics = 12;
getCustomMetricsOrThrow
in interface StoreTypes.StateOperatorProgressOrBuilder
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.StateOperatorProgress parseFrom(java.nio.ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.StateOperatorProgress parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.StateOperatorProgress parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.StateOperatorProgress parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.StateOperatorProgress parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.StateOperatorProgress parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.StateOperatorProgress parseFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.StateOperatorProgress parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static StoreTypes.StateOperatorProgress parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.StateOperatorProgress parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static StoreTypes.StateOperatorProgress parseFrom(com.google.protobuf.CodedInputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.StateOperatorProgress parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public StoreTypes.StateOperatorProgress.Builder newBuilderForType()
newBuilderForType
in interface com.google.protobuf.Message
newBuilderForType
in interface com.google.protobuf.MessageLite
public static StoreTypes.StateOperatorProgress.Builder newBuilder()
public static StoreTypes.StateOperatorProgress.Builder newBuilder(StoreTypes.StateOperatorProgress prototype)
public StoreTypes.StateOperatorProgress.Builder toBuilder()
toBuilder
in interface com.google.protobuf.Message
toBuilder
in interface com.google.protobuf.MessageLite
public static StoreTypes.StateOperatorProgress getDefaultInstance()
public static com.google.protobuf.Parser<StoreTypes.StateOperatorProgress> parser()
public com.google.protobuf.Parser<StoreTypes.StateOperatorProgress> getParserForType()
getParserForType
in interface com.google.protobuf.Message
getParserForType
in interface com.google.protobuf.MessageLite
getParserForType
in class com.google.protobuf.GeneratedMessageV3
public StoreTypes.StateOperatorProgress getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder