public interface Scheduler<T>
Modifier and Type | Interface and Description |
---|---|
static class |
Scheduler.SubmissionState |
Modifier and Type | Method and Description |
---|---|
QueryIdentifier |
findQueryByFragment(String fragmentId) |
Set<String> |
getExecutorsStatus() |
int |
getNumActive() |
void |
killFragment(String fragmentId)
Attempt to kill the fragment with the specified fragmentId
|
Scheduler.SubmissionState |
schedule(T t)
Schedule the task or throw RejectedExecutionException if queues are full
|
Scheduler.SubmissionState schedule(T t)
t
- - task to schedulevoid killFragment(String fragmentId)
fragmentId
- int getNumActive()
QueryIdentifier findQueryByFragment(String fragmentId)
Copyright © 2021 The Apache Software Foundation. All rights reserved.