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() |
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
- QueryIdentifier findQueryByFragment(String fragmentId)
Copyright © 2016 The Apache Software Foundation. All rights reserved.