Package org.apache.storm.executor

Interface IRunningExecutor

All Known Implementing Classes:
ExecutorShutdown
public interface IRunningExecutor

  • Method Details

    • renderStats

      ExecutorStats renderStats()

    • getExecutorId

      List<Long> getExecutorId()

    • credentialsChanged

      void credentialsChanged(Credentials credentials)

    • loadChanged

      void loadChanged(LoadMapping loadMapping)

    • getReceiveQueue

      JCQueue getReceiveQueue()

    • publishFlushTuple

      boolean publishFlushTuple()