Package org.apache.storm.executor
Interface IRunningExecutor
-
- All Known Implementing Classes:
ExecutorShutdown
public interface IRunningExecutor
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidcredentialsChanged(Credentials credentials)List<Long>getExecutorId()JCQueuegetReceiveQueue()voidloadChanged(LoadMapping loadMapping)booleanpublishFlushTuple()ExecutorStatsrenderStats()
-
-
-
Method Detail
-
renderStats
ExecutorStats renderStats()
-
credentialsChanged
void credentialsChanged(Credentials credentials)
-
loadChanged
void loadChanged(LoadMapping loadMapping)
-
getReceiveQueue
JCQueue getReceiveQueue()
-
publishFlushTuple
boolean publishFlushTuple()
-
-