Package org.apache.spark.status.protobuf

Interface StoreTypes.StateOperatorProgressOrBuilder

All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
All Known Implementing Classes:
StoreTypes.StateOperatorProgress, StoreTypes.StateOperatorProgress.Builder
Enclosing class:
StoreTypes
public static interface StoreTypes.StateOperatorProgressOrBuilder extends com.google.protobuf.MessageOrBuilder

  • Method Details

    • hasOperatorName

      boolean hasOperatorName()
      optional string operator_name = 1;
      Returns:
      Whether the operatorName field is set.

    • getOperatorName

      String getOperatorName()
      optional string operator_name = 1;
      Returns:
      The operatorName.

    • getOperatorNameBytes

      com.google.protobuf.ByteString getOperatorNameBytes()
      optional string operator_name = 1;
      Returns:
      The bytes for operatorName.

    • getNumRowsTotal

      long getNumRowsTotal()
      int64 num_rows_total = 2;
      Returns:
      The numRowsTotal.

    • getNumRowsUpdated

      long getNumRowsUpdated()
      int64 num_rows_updated = 3;
      Returns:
      The numRowsUpdated.

    • getAllUpdatesTimeMs

      long getAllUpdatesTimeMs()
      int64 all_updates_time_ms = 4;
      Returns:
      The allUpdatesTimeMs.

    • getNumRowsRemoved

      long getNumRowsRemoved()
      int64 num_rows_removed = 5;
      Returns:
      The numRowsRemoved.

    • getAllRemovalsTimeMs

      long getAllRemovalsTimeMs()
      int64 all_removals_time_ms = 6;
      Returns:
      The allRemovalsTimeMs.

    • getCommitTimeMs

      long getCommitTimeMs()
      int64 commit_time_ms = 7;
      Returns:
      The commitTimeMs.

    • getMemoryUsedBytes

      long getMemoryUsedBytes()
      int64 memory_used_bytes = 8;
      Returns:
      The memoryUsedBytes.

    • getNumRowsDroppedByWatermark

      long getNumRowsDroppedByWatermark()
      int64 num_rows_dropped_by_watermark = 9;
      Returns:
      The numRowsDroppedByWatermark.

    • getNumShufflePartitions

      long getNumShufflePartitions()
      int64 num_shuffle_partitions = 10;
      Returns:
      The numShufflePartitions.

    • getNumStateStoreInstances

      long getNumStateStoreInstances()
      int64 num_state_store_instances = 11;
      Returns:
      The numStateStoreInstances.

    • getCustomMetricsCount

      int getCustomMetricsCount()
      map<string, int64> custom_metrics = 12;

    • containsCustomMetrics

      boolean containsCustomMetrics(String key)
      map<string, int64> custom_metrics = 12;

    • getCustomMetrics

      @Deprecated Map<String,Long> getCustomMetrics()
      Deprecated.
      Use getCustomMetricsMap() instead.

    • getCustomMetricsMap

      Map<String,Long> getCustomMetricsMap()
      map<string, int64> custom_metrics = 12;

    • getCustomMetricsOrDefault

      long getCustomMetricsOrDefault(String key, long defaultValue)
      map<string, int64> custom_metrics = 12;

    • getCustomMetricsOrThrow

      long getCustomMetricsOrThrow(String key)
      map<string, int64> custom_metrics = 12;