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