Package org.apache.drill.yarn.appMaster.http

Class AbstractTasksModel.TaskModel

java.lang.Object
org.apache.drill.yarn.appMaster.http.AbstractTasksModel.TaskModel
Enclosing class:
AbstractTasksModel
public static class AbstractTasksModel.TaskModel extends Object

  • Field Details

    • id

      public int id

    • groupName

      protected String groupName

    • isLive

      protected boolean isLive

    • taskState

      protected TaskState taskState

    • taskStateHint

      protected String taskStateHint

    • state

      protected String state

    • cancelled

      protected boolean cancelled

    • trackingState

      protected String trackingState

    • trackingStateHint

      protected String trackingStateHint

    • container

      protected org.apache.hadoop.yarn.api.records.Container container

    • endpoint

      protected CoordinationProtos.DrillbitEndpoint endpoint

    • startTime

      protected long startTime

    • memoryMb

      protected int memoryMb

    • vcores

      protected int vcores

    • disks

      protected double disks

    • containerId

      protected String containerId

    • endTime

      protected long endTime

    • disposition

      protected String disposition

    • tryCount

      protected int tryCount

  • Constructor Details

    • TaskModel

      public TaskModel(Task task, boolean live)

  • Method Details

    • reformatDiagnostics

      public static String reformatDiagnostics(String orig)
      YARN diagnostics are verbose: they contain a stack trace of the YARN node manager thread (not Drill), and contain blank lines, the container ID, etc. Remove unnecessary cruft to make the diagnostics simpler and smaller in the Web UI.
      Parameters:
      orig - YARN diagnostics
      Returns:
      cleaned-up version.

    • getTaskId

      public String getTaskId()

    • getGroupName

      public String getGroupName()

    • isLive

      public boolean isLive()

    • getHost

      public String getHost()

    • getLink

      public String getLink()

    • getState

      public String getState()

    • getStateHint

      public String getStateHint()

    • isCancelled

      public boolean isCancelled()

    • isCancellable

      public boolean isCancellable()

    • getTrackingState

      public String getTrackingState()

    • getTrackingStateHint

      public String getTrackingStateHint()

    • getStartTime

      public String getStartTime()

    • getMemory

      public int getMemory()

    • getVcores

      public int getVcores()

    • getDisks

      public String getDisks()

    • hasContainer

      public boolean hasContainer()

    • getContainerId

      public String getContainerId()

    • getNmLink

      public String getNmLink()

    • getDisposition

      public String getDisposition()

    • getTryCount

      public int getTryCount()

    • displayString

      public String displayString(String value)

    • getEndTime

      public String getEndTime()