public class ExecutorShutdown extends Object implements Shutdownable, IRunningExecutor
Constructor and Description |
---|
ExecutorShutdown(Executor executor,
List<Utils.SmartThread> threads,
ArrayList<Task> taskDatas,
JCQueue recvQueue) |
Modifier and Type | Method and Description |
---|---|
void |
credentialsChanged(Credentials credentials) |
List<Long> |
getExecutorId() |
JCQueue |
getReceiveQueue() |
void |
loadChanged(LoadMapping loadMapping) |
boolean |
publishFlushTuple() |
ExecutorStats |
renderStats() |
void |
shutdown() |
public ExecutorStats renderStats()
renderStats
in interface IRunningExecutor
public List<Long> getExecutorId()
getExecutorId
in interface IRunningExecutor
public void credentialsChanged(Credentials credentials)
credentialsChanged
in interface IRunningExecutor
public void loadChanged(LoadMapping loadMapping)
loadChanged
in interface IRunningExecutor
public JCQueue getReceiveQueue()
getReceiveQueue
in interface IRunningExecutor
public boolean publishFlushTuple()
publishFlushTuple
in interface IRunningExecutor
public void shutdown()
shutdown
in interface Shutdownable
Copyright © 2022 The Apache Software Foundation. All rights reserved.