generateSegmentIdsWithShardSpecsForReplace(
shardSpec = new DimensionRangeShardSpec(shardColumns, start, end, segmentNumber, ranges.size());
}
- retVal[partitionNumber] = new SegmentIdWithShardSpec(task.getDataSource(), interval, version, shardSpec);
+ retVal[partitionNumber] = new SegmentIdWithShardSpec(destination.getDataSource(), interval, version, shardSpec);
}
}
return Arrays.asList(retVal);
}
- /**
- * Returns a complete list of task ids, ordered by worker number. The Nth task has worker number N.
- *
- * If the currently-running set of tasks is incomplete, returns an absent Optional.
- */
@Override
public List getTaskIds()
{
- if (workerTaskLauncher == null) {
+ if (workerManager == null) {
return Collections.emptyList();
}
- return workerTaskLauncher.getActiveTasks();
+ return workerManager.getWorkerIds();
}
@SuppressWarnings({"unchecked", "rawtypes"})
@@ -1225,7 +1144,7 @@ private Int2ObjectMap