org.apache.storm.executor

Interface IRunningExecutor

All Known Implementing Classes:

ExecutorShutdown

public interface IRunningExecutor

Method Summary

Modifier and Type	Method and Description
void	credentialsChanged(Credentials credentials)
List<Long>	getExecutorId()
JCQueue	getReceiveQueue()
void	loadChanged(LoadMapping loadMapping)
boolean	publishFlushTuple()
ExecutorStats	renderStats()

Method Detail

renderStats

ExecutorStats renderStats()

getExecutorId

List<Long> getExecutorId()

credentialsChanged

void credentialsChanged(Credentials credentials)

loadChanged

void loadChanged(LoadMapping loadMapping)

getReceiveQueue

JCQueue getReceiveQueue()

publishFlushTuple

boolean publishFlushTuple()