public class TaskIdsPermitsBarrier extends Object
| Constructor and Description |
|---|
TaskIdsPermitsBarrier(org.apache.hadoop.util.Progressable progressable)
Constructor
|
| Modifier and Type | Method and Description |
|---|---|
void |
releaseOnePermit()
Release one permit.
|
void |
releasePermits(long permits)
Release some permits.
|
void |
requirePermits(long permits,
int taskId)
Require more permits.
|
void |
waitForRequiredPermits(Set<Integer> expectedTaskIds)
Wait until permits have been required desired number of times,
and all required permits are available
|
public TaskIdsPermitsBarrier(org.apache.hadoop.util.Progressable progressable)
progressable - Progressable for reporting progresspublic void waitForRequiredPermits(Set<Integer> expectedTaskIds)
expectedTaskIds - List of task ids which we are waiting permits frompublic void requirePermits(long permits,
int taskId)
permits - Number of permits to requiretaskId - Task id which required permitspublic void releaseOnePermit()
public void releasePermits(long permits)
permits - Number of permits to releaseCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.