public static class AbandonedCoordCheckerService.AbandonedCoordCheckerRunnable extends Object implements Runnable
Constructor and Description |
---|
AbandonedCoordCheckerService.AbandonedCoordCheckerRunnable(int failureLimit) |
AbandonedCoordCheckerService.AbandonedCoordCheckerRunnable(int failureLimit,
boolean shouldKill) |
Modifier and Type | Method and Description |
---|---|
void |
addCoordToMessage(CoordinatorJobBean job,
String killStatus,
StringBuilder msg) |
void |
addTableHeader(StringBuilder msg) |
void |
addTableTail(StringBuilder msg) |
void |
run() |
void |
sendMail(String body) |
public AbandonedCoordCheckerService.AbandonedCoordCheckerRunnable(int failureLimit)
public AbandonedCoordCheckerService.AbandonedCoordCheckerRunnable(int failureLimit, boolean shouldKill)
public void addCoordToMessage(CoordinatorJobBean job, String killStatus, StringBuilder msg)
public void addTableHeader(StringBuilder msg)
public void addTableTail(StringBuilder msg)
Copyright © 2018 Apache Software Foundation. All rights reserved.