public static class AbandonedCoordCheckerService.AbandonedCoordCheckerRunnable extends java.lang.Object implements java.lang.Runnable
| Constructor and Description |
|---|
AbandonedCoordCheckerService.AbandonedCoordCheckerRunnable(int failureLimit) |
AbandonedCoordCheckerService.AbandonedCoordCheckerRunnable(int failureLimit,
boolean shouldKill) |
| Modifier and Type | Method and Description |
|---|---|
void |
addCoordToMessage(CoordinatorJobBean job,
java.lang.String killStatus,
java.lang.StringBuilder msg) |
void |
addTableHeader(java.lang.StringBuilder msg) |
void |
addTableTail(java.lang.StringBuilder msg) |
void |
run() |
void |
sendMail(java.lang.String body) |
public AbandonedCoordCheckerService.AbandonedCoordCheckerRunnable(int failureLimit)
public AbandonedCoordCheckerService.AbandonedCoordCheckerRunnable(int failureLimit, boolean shouldKill)
public void run()
run in interface java.lang.Runnablepublic void addCoordToMessage(CoordinatorJobBean job, java.lang.String killStatus, java.lang.StringBuilder msg)
public void addTableHeader(java.lang.StringBuilder msg)
public void addTableTail(java.lang.StringBuilder msg)
public void sendMail(java.lang.String body) throws java.lang.Exception
java.lang.ExceptionCopyright © 2017 Apache Software Foundation. All Rights Reserved.