public static interface StoreTypes.StateOperatorProgressOrBuilder
extends com.google.protobuf.MessageOrBuilder
Modifier and Type | Method and Description |
---|---|
boolean |
containsCustomMetrics(String key)
map<string, int64> custom_metrics = 12; |
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; |
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; |
boolean |
hasOperatorName()
optional string operator_name = 1; |
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
boolean hasOperatorName()
optional string operator_name = 1;
String getOperatorName()
optional string operator_name = 1;
com.google.protobuf.ByteString getOperatorNameBytes()
optional string operator_name = 1;
long getNumRowsTotal()
int64 num_rows_total = 2;
long getNumRowsUpdated()
int64 num_rows_updated = 3;
long getAllUpdatesTimeMs()
int64 all_updates_time_ms = 4;
long getNumRowsRemoved()
int64 num_rows_removed = 5;
long getAllRemovalsTimeMs()
int64 all_removals_time_ms = 6;
long getCommitTimeMs()
int64 commit_time_ms = 7;
long getMemoryUsedBytes()
int64 memory_used_bytes = 8;
long getNumRowsDroppedByWatermark()
int64 num_rows_dropped_by_watermark = 9;
long getNumShufflePartitions()
int64 num_shuffle_partitions = 10;
long getNumStateStoreInstances()
int64 num_state_store_instances = 11;
int getCustomMetricsCount()
map<string, int64> custom_metrics = 12;
boolean containsCustomMetrics(String key)
map<string, int64> custom_metrics = 12;
@Deprecated java.util.Map<String,Long> getCustomMetrics()
getCustomMetricsMap()
instead.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;