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, hasOneofboolean 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;