Package org.apache.spark.status.protobuf

Interface StoreTypes.ExecutorSummaryOrBuilder

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

  • Method Details

    • hasId

      boolean hasId()
      optional string id = 1;
      Returns:
      Whether the id field is set.

    • getId

      String getId()
      optional string id = 1;
      Returns:
      The id.

    • getIdBytes

      com.google.protobuf.ByteString getIdBytes()
      optional string id = 1;
      Returns:
      The bytes for id.

    • hasHostPort

      boolean hasHostPort()
      optional string host_port = 2;
      Returns:
      Whether the hostPort field is set.

    • getHostPort

      String getHostPort()
      optional string host_port = 2;
      Returns:
      The hostPort.

    • getHostPortBytes

      com.google.protobuf.ByteString getHostPortBytes()
      optional string host_port = 2;
      Returns:
      The bytes for hostPort.

    • getIsActive

      boolean getIsActive()
      bool is_active = 3;
      Returns:
      The isActive.

    • getRddBlocks

      int getRddBlocks()
      int32 rdd_blocks = 4;
      Returns:
      The rddBlocks.

    • getMemoryUsed

      long getMemoryUsed()
      int64 memory_used = 5;
      Returns:
      The memoryUsed.

    • getDiskUsed

      long getDiskUsed()
      int64 disk_used = 6;
      Returns:
      The diskUsed.

    • getTotalCores

      int getTotalCores()
      int32 total_cores = 7;
      Returns:
      The totalCores.

    • getMaxTasks

      int getMaxTasks()
      int32 max_tasks = 8;
      Returns:
      The maxTasks.

    • getActiveTasks

      int getActiveTasks()
      int32 active_tasks = 9;
      Returns:
      The activeTasks.

    • getFailedTasks

      int getFailedTasks()
      int32 failed_tasks = 10;
      Returns:
      The failedTasks.

    • getCompletedTasks

      int getCompletedTasks()
      int32 completed_tasks = 11;
      Returns:
      The completedTasks.

    • getTotalTasks

      int getTotalTasks()
      int32 total_tasks = 12;
      Returns:
      The totalTasks.

    • getTotalDuration

      long getTotalDuration()
      int64 total_duration = 13;
      Returns:
      The totalDuration.

    • getTotalGcTime

      long getTotalGcTime()
      int64 total_gc_time = 14;
      Returns:
      The totalGcTime.

    • getTotalInputBytes

      long getTotalInputBytes()
      int64 total_input_bytes = 15;
      Returns:
      The totalInputBytes.

    • getTotalShuffleRead

      long getTotalShuffleRead()
      int64 total_shuffle_read = 16;
      Returns:
      The totalShuffleRead.

    • getTotalShuffleWrite

      long getTotalShuffleWrite()
      int64 total_shuffle_write = 17;
      Returns:
      The totalShuffleWrite.

    • getIsBlacklisted

      boolean getIsBlacklisted()
      bool is_blacklisted = 18;
      Returns:
      The isBlacklisted.

    • getMaxMemory

      long getMaxMemory()
      int64 max_memory = 19;
      Returns:
      The maxMemory.

    • getAddTime

      long getAddTime()
      int64 add_time = 20;
      Returns:
      The addTime.

    • hasRemoveTime

      boolean hasRemoveTime()
      optional int64 remove_time = 21;
      Returns:
      Whether the removeTime field is set.

    • getRemoveTime

      long getRemoveTime()
      optional int64 remove_time = 21;
      Returns:
      The removeTime.

    • hasRemoveReason

      boolean hasRemoveReason()
      optional string remove_reason = 22;
      Returns:
      Whether the removeReason field is set.

    • getRemoveReason

      String getRemoveReason()
      optional string remove_reason = 22;
      Returns:
      The removeReason.

    • getRemoveReasonBytes

      com.google.protobuf.ByteString getRemoveReasonBytes()
      optional string remove_reason = 22;
      Returns:
      The bytes for removeReason.

    • getExecutorLogsCount

      int getExecutorLogsCount()
      map<string, string> executor_logs = 23;

    • containsExecutorLogs

      boolean containsExecutorLogs(String key)
      map<string, string> executor_logs = 23;

    • getExecutorLogs

      @Deprecated Map<String,String> getExecutorLogs()
      Deprecated.
      Use getExecutorLogsMap() instead.

    • getExecutorLogsMap

      Map<String,String> getExecutorLogsMap()
      map<string, string> executor_logs = 23;

    • getExecutorLogsOrDefault

      String getExecutorLogsOrDefault(String key, String defaultValue)
      map<string, string> executor_logs = 23;

    • getExecutorLogsOrThrow

      String getExecutorLogsOrThrow(String key)
      map<string, string> executor_logs = 23;

    • hasMemoryMetrics

      boolean hasMemoryMetrics()
      optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
      Returns:
      Whether the memoryMetrics field is set.

    • getMemoryMetrics

      StoreTypes.MemoryMetrics getMemoryMetrics()
      optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
      Returns:
      The memoryMetrics.

    • getMemoryMetricsOrBuilder

      StoreTypes.MemoryMetricsOrBuilder getMemoryMetricsOrBuilder()
      optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;

    • getBlacklistedInStagesList

      List<Long> getBlacklistedInStagesList()
      repeated int64 blacklisted_in_stages = 25;
      Returns:
      A list containing the blacklistedInStages.

    • getBlacklistedInStagesCount

      int getBlacklistedInStagesCount()
      repeated int64 blacklisted_in_stages = 25;
      Returns:
      The count of blacklistedInStages.

    • getBlacklistedInStages

      long getBlacklistedInStages(int index)
      repeated int64 blacklisted_in_stages = 25;
      Parameters:
      index - The index of the element to return.
      Returns:
      The blacklistedInStages at the given index.

    • hasPeakMemoryMetrics

      boolean hasPeakMemoryMetrics()
      optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
      Returns:
      Whether the peakMemoryMetrics field is set.

    • getPeakMemoryMetrics

      StoreTypes.ExecutorMetrics getPeakMemoryMetrics()
      optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
      Returns:
      The peakMemoryMetrics.

    • getPeakMemoryMetricsOrBuilder

      StoreTypes.ExecutorMetricsOrBuilder getPeakMemoryMetricsOrBuilder()
      optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;

    • getAttributesCount

      int getAttributesCount()
      map<string, string> attributes = 27;

    • containsAttributes

      boolean containsAttributes(String key)
      map<string, string> attributes = 27;

    • getAttributes

      @Deprecated Map<String,String> getAttributes()
      Deprecated.
      Use getAttributesMap() instead.

    • getAttributesMap

      Map<String,String> getAttributesMap()
      map<string, string> attributes = 27;

    • getAttributesOrDefault

      String getAttributesOrDefault(String key, String defaultValue)
      map<string, string> attributes = 27;

    • getAttributesOrThrow

      String getAttributesOrThrow(String key)
      map<string, string> attributes = 27;

    • getResourcesCount

      int getResourcesCount()
      map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;

    • containsResources

      boolean containsResources(String key)
      map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;

    • getResources

      @Deprecated Map<String,StoreTypes.ResourceInformation> getResources()
      Deprecated.
      Use getResourcesMap() instead.

    • getResourcesMap

      Map<String,StoreTypes.ResourceInformation> getResourcesMap()
      map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;

    • getResourcesOrDefault

      StoreTypes.ResourceInformation getResourcesOrDefault(String key, StoreTypes.ResourceInformation defaultValue)
      map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;

    • getResourcesOrThrow

      StoreTypes.ResourceInformation getResourcesOrThrow(String key)
      map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;

    • getResourceProfileId

      int getResourceProfileId()
      int32 resource_profile_id = 29;
      Returns:
      The resourceProfileId.

    • getIsExcluded

      boolean getIsExcluded()
      bool is_excluded = 30;
      Returns:
      The isExcluded.

    • getExcludedInStagesList

      List<Long> getExcludedInStagesList()
      repeated int64 excluded_in_stages = 31;
      Returns:
      A list containing the excludedInStages.

    • getExcludedInStagesCount

      int getExcludedInStagesCount()
      repeated int64 excluded_in_stages = 31;
      Returns:
      The count of excludedInStages.

    • getExcludedInStages

      long getExcludedInStages(int index)
      repeated int64 excluded_in_stages = 31;
      Parameters:
      index - The index of the element to return.
      Returns:
      The excludedInStages at the given index.