Rename Driver.isBlocked to getBlockedFuture
@@ -270,7 +270,7 @@ public class Driver
// check if operator is blocked
Operator current = operators.get(0);
- ListenableFuture<?> blocked = isBlocked(current);
+ ListenableFuture<?> blocked = getBlockedFuture(current);
if (!blocked.isDone()) {
current.getOperatorContext().recordBlocked(blocked);
return blocked;
@@ -289,10 +289,10 @@ public class Driver
Operator next = operators.get(i + 1);
// skip blocked operators
- if (!isBlocked(current).isDone()) {
+ if (!getBlockedFuture(current).isDone()) {
continue;
}
- if (!isBlocked(next).isDone()) {
+ if (!getBlockedFuture(next).isDone()) {
continue;
}
@@ -330,7 +330,7 @@ public class Driver
List<Operator> blockedOperators = new ArrayList<>();
List<ListenableFuture<?>> blockedFutures = new ArrayList<>();
for (Operator operator : operators) {
- ListenableFuture<?> blocked = isBlocked(operator);
+ ListenableFuture<?> blocked = getBlockedFuture(operator);
if (!blocked.isDone()) {
blockedOperators.add(operator);
blockedFutures.add(blocked);
@@ -457,7 +457,7 @@ public class Driver
}
}
- private static ListenableFuture<?> isBlocked(Operator operator)
+ private static ListenableFuture<?> getBlockedFuture(Operator operator)
{
ListenableFuture<?> blocked = operator.isBlocked();
if (blocked.isDone()) {
