| Package | Description |
|---|---|
| org.apache.hadoop.hbase.coordination | |
| org.apache.hadoop.hbase.master |
| Modifier and Type | Field and Description |
|---|---|
private ConcurrentMap<String,SplitLogManager.Task> |
SplitLogManagerCoordination.SplitLogManagerDetails.tasks |
| Modifier and Type | Method and Description |
|---|---|
(package private) SplitLogManager.Task |
ZKSplitLogManagerCoordination.findOrCreateOrphanTask(String path) |
| Modifier and Type | Method and Description |
|---|---|
ConcurrentMap<String,SplitLogManager.Task> |
SplitLogManagerCoordination.SplitLogManagerDetails.getTasks() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
SplitLogManagerCoordination.resubmitTask(String taskName,
SplitLogManager.Task task,
SplitLogManager.ResubmitDirective force)
Resubmit the task in case if found unassigned or failed
|
boolean |
ZKSplitLogManagerCoordination.resubmitTask(String path,
SplitLogManager.Task task,
SplitLogManager.ResubmitDirective directive) |
| Constructor and Description |
|---|
SplitLogManagerCoordination.SplitLogManagerDetails(ConcurrentMap<String,SplitLogManager.Task> tasks,
MasterServices master,
Set<String> failedDeletions,
ServerName serverName) |
ZKSplitLogManagerCoordination.ZkSplitLogManagerDetails(ConcurrentMap<String,SplitLogManager.Task> tasks,
MasterServices master,
Set<String> failedDeletions,
ServerName serverName) |
| Modifier and Type | Field and Description |
|---|---|
private ConcurrentMap<String,SplitLogManager.Task> |
SplitLogManager.tasks |
| Modifier and Type | Method and Description |
|---|---|
private SplitLogManager.Task |
SplitLogManager.createTaskIfAbsent(String path,
SplitLogManager.TaskBatch batch) |
(package private) SplitLogManager.Task |
SplitLogManager.findOrCreateOrphanTask(String path) |
| Modifier and Type | Method and Description |
|---|---|
(package private) ConcurrentMap<String,SplitLogManager.Task> |
SplitLogManager.getTasks() |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.