Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

TaskStorage: Rename getRunningTasks -> getActiveTasks

This commit is contained in:
Gian Merlino 2013-12-02 15:05:33 -08:00
parent 64e75becba
commit 47c1c8cab2
4 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
indexing-service/src/main/java/io/druid/indexing/overlord/DbTaskStorage.java
View File

@ -220,7 +220,7 @@ public class DbTaskStorage implements TaskStorage
} }
@Override @Override
public List<Task> getRunningTasks() public List<Task> getActiveTasks()
{ {
return dbi.withHandle( return dbi.withHandle(
new HandleCallback<List<Task>>() new HandleCallback<List<Task>>()

2
indexing-service/src/main/java/io/druid/indexing/overlord/HeapMemoryTaskStorage.java
View File

@ -128,7 +128,7 @@ public class HeapMemoryTaskStorage implements TaskStorage
} }
@Override @Override
public List<Task> getRunningTasks() public List<Task> getActiveTasks()
{ {
giant.lock(); giant.lock();

2
indexing-service/src/main/java/io/druid/indexing/overlord/TaskQueue.java
View File

@ -100,7 +100,7 @@ public class TaskQueue
// Get all running tasks and their locks // Get all running tasks and their locks
final Multimap<TaskLock, Task> tasksByLock = ArrayListMultimap.create(); final Multimap<TaskLock, Task> tasksByLock = ArrayListMultimap.create();
for (final Task task : taskStorage.getRunningTasks()) { for (final Task task : taskStorage.getActiveTasks()) {
try { try {
final List<TaskLock> taskLocks = taskStorage.getLocks(task.getId()); final List<TaskLock> taskLocks = taskStorage.getLocks(task.getId());

4
indexing-service/src/main/java/io/druid/indexing/overlord/TaskStorage.java
View File

@ -77,9 +77,9 @@ public interface TaskStorage
public List<TaskAction> getAuditLogs(String taskid); public List<TaskAction> getAuditLogs(String taskid);
/** /**
* Returns a list of currently-running tasks as stored in the storage facility, in no particular order. * Returns a list of currently running or pending tasks as stored in the storage facility, in no particular order.
*/ */
public List<Task> getRunningTasks(); public List<Task> getActiveTasks();
/** /**
* Returns a list of locks for a particular task. * Returns a list of locks for a particular task.