public class ExecutorShutdown extends Object implements Shutdownable, IRunningExecutor
| Constructor and Description |
|---|
ExecutorShutdown(Executor executor,
List<Utils.SmartThread> threads,
ArrayList<Task> taskDatas,
JCQueue recvQueue) |
| Modifier and Type | Method and Description |
|---|---|
void |
credentialsChanged(Credentials credentials) |
List<Long> |
getExecutorId() |
JCQueue |
getReceiveQueue() |
void |
loadChanged(LoadMapping loadMapping) |
boolean |
publishFlushTuple() |
ExecutorStats |
renderStats() |
void |
shutdown() |
public ExecutorStats renderStats()
renderStats in interface IRunningExecutorpublic List<Long> getExecutorId()
getExecutorId in interface IRunningExecutorpublic void credentialsChanged(Credentials credentials)
credentialsChanged in interface IRunningExecutorpublic void loadChanged(LoadMapping loadMapping)
loadChanged in interface IRunningExecutorpublic JCQueue getReceiveQueue()
getReceiveQueue in interface IRunningExecutorpublic boolean publishFlushTuple()
publishFlushTuple in interface IRunningExecutorpublic void shutdown()
shutdown in interface ShutdownableCopyright © 2021 The Apache Software Foundation. All rights reserved.