Package org.apache.storm.executor
Class ExecutorShutdown
java.lang.Object
org.apache.storm.executor.ExecutorShutdown
- All Implemented Interfaces:
Shutdownable,IRunningExecutor
-
Constructor Summary
ConstructorsConstructorDescriptionExecutorShutdown(Executor executor, List<Utils.SmartThread> threads, ArrayList<Task> taskDatas, JCQueue recvQueue) -
Method Summary
Modifier and TypeMethodDescriptionvoidcredentialsChanged(Credentials credentials) voidloadChanged(LoadMapping loadMapping) booleanvoidshutdown()
-
Constructor Details
-
ExecutorShutdown
-
-
Method Details
-
renderStats
- Specified by:
renderStatsin interfaceIRunningExecutor
-
getExecutorId
- Specified by:
getExecutorIdin interfaceIRunningExecutor
-
credentialsChanged
- Specified by:
credentialsChangedin interfaceIRunningExecutor
-
loadChanged
- Specified by:
loadChangedin interfaceIRunningExecutor
-
getReceiveQueue
- Specified by:
getReceiveQueuein interfaceIRunningExecutor
-
publishFlushTuple
public boolean publishFlushTuple()- Specified by:
publishFlushTuplein interfaceIRunningExecutor
-
shutdown
public void shutdown()- Specified by:
shutdownin interfaceShutdownable
-