Package org.apache.storm.executor
Class ExecutorShutdown
- java.lang.Object
-
- org.apache.storm.executor.ExecutorShutdown
-
- All Implemented Interfaces:
Shutdownable,IRunningExecutor
public class ExecutorShutdown extends Object implements Shutdownable, IRunningExecutor
-
-
Constructor Summary
Constructors Constructor Description ExecutorShutdown(Executor executor, List<Utils.SmartThread> threads, ArrayList<Task> taskDatas, JCQueue recvQueue)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcredentialsChanged(Credentials credentials)List<Long>getExecutorId()JCQueuegetReceiveQueue()voidloadChanged(LoadMapping loadMapping)booleanpublishFlushTuple()ExecutorStatsrenderStats()voidshutdown()
-
-
-
Method Detail
-
renderStats
public ExecutorStats renderStats()
- Specified by:
renderStatsin interfaceIRunningExecutor
-
getExecutorId
public List<Long> getExecutorId()
- Specified by:
getExecutorIdin interfaceIRunningExecutor
-
credentialsChanged
public void credentialsChanged(Credentials credentials)
- Specified by:
credentialsChangedin interfaceIRunningExecutor
-
loadChanged
public void loadChanged(LoadMapping loadMapping)
- Specified by:
loadChangedin interfaceIRunningExecutor
-
getReceiveQueue
public JCQueue getReceiveQueue()
- Specified by:
getReceiveQueuein interfaceIRunningExecutor
-
publishFlushTuple
public boolean publishFlushTuple()
- Specified by:
publishFlushTuplein interfaceIRunningExecutor
-
shutdown
public void shutdown()
- Specified by:
shutdownin interfaceShutdownable
-
-