Package org.apache.storm.executor
Class Executor
java.lang.Object
org.apache.storm.executor.Executor
- All Implemented Interfaces:
Callable
,org.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>
,JCQueue.Consumer
- Direct Known Subclasses:
BoltExecutor
,SpoutExecutor
-
Field Summary
Modifier and TypeFieldDescriptionprotected final boolean
protected final String
protected ExecutorTransfer
protected final List<LoadAwareCustomStreamGrouping>
protected final Boolean
protected String
protected int
protected final Boolean
protected final AtomicBoolean
protected final org.apache.storm.shade.org.jctools.queues.MpscChunkedArrayQueue<AddressedTuple>
protected final Random
protected final JCQueue
protected final IReportError
protected final ReportErrorAndDie
protected final BooleanSupplier
protected final HashMap
protected final AtomicBoolean
protected final IStormClusterState
protected final AtomicReference<Map<String,
DebugOptions>> protected final String
protected final Map<String,
Map<String, LoadAwareCustomStreamGrouping>> protected final Runnable
protected final String
protected final WorkerState
protected final CountDownLatch
protected final WorkerTopologyContext
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
execute()
separated from mkExecutor in order to replace executor transfer in executor data for testing.void
flush()
abstract CommonStats
getStats()
getType()
void
void
metricsTick
(Task task, TupleImpl tuple) static Executor
mkExecutor
(WorkerState workerState, List<Long> executorId, Map<String, String> credentials) boolean
void
reflectNewLoadMapping
(LoadMapping loadMapping) boolean
void
setLocalExecutorTransfer
(ExecutorTransfer executorTransfer) void
protected void
protected void
setupTicks
(boolean isSpout) abstract void
tupleActionFn
(int taskId, TupleImpl tuple) protected void
-
Field Details
-
workerData
-
workerTopologyContext
-
executorId
-
taskIds
-
componentId
-
openOrPrepareWasCalled
-
topoConf
-
conf
-
stormId
-
workerReady
-
stormActive
-
stormComponentDebug
-
suicideFn
-
stormClusterState
-
taskToComponent
-
intervalToTaskToMetricToRegistry
-
streamToComponentToGrouper
-
groupers
-
reportErrorDie
-
sampler
-
type
-
reportError
-
rand
-
receiveQueue
-
credentials
-
isDebug
-
hasEventLoggers
-
ackingEnabled
protected final boolean ackingEnabled -
pendingEmits
protected final org.apache.storm.shade.org.jctools.queues.MpscChunkedArrayQueue<AddressedTuple> pendingEmits -
executorTransfer
-
idToTask
-
idToTaskBase
protected int idToTaskBase -
hostname
-
-
Constructor Details
-
Executor
-
-
Method Details
-
mkExecutor
-
getPendingEmits
-
execute
separated from mkExecutor in order to replace executor transfer in executor data for testing.- Throws:
Exception
-
tupleActionFn
- Throws:
Exception
-
accept
- Specified by:
accept
in interfaceJCQueue.Consumer
- Specified by:
accept
in interfaceorg.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>
-
setNeedToRefreshCreds
public void setNeedToRefreshCreds() -
updateExecCredsIfRequired
protected void updateExecCredsIfRequired() -
flush
public void flush()- Specified by:
flush
in interfaceJCQueue.Consumer
-
metricsTick
-
setupMetrics
protected void setupMetrics() -
setupTicks
protected void setupTicks(boolean isSpout) -
reflectNewLoadMapping
-
publishFlushTuple
public boolean publishFlushTuple() -
getExecutorId
-
getTaskIds
-
getComponentId
-
getOpenOrPrepareWasCalled
-
getTopoConf
-
getStormId
-
getStats
-
getType
-
getIsDebug
-
getExecutorTransfer
-
getReportError
-
getWorkerTopologyContext
-
samplerCheck
public boolean samplerCheck() -
getStormComponentDebug
-
getReceiveQueue
-
getStormClusterState
-
getWorkerData
-
getStreamToComponentToGrouper
-
getIntervalToTaskToMetricToRegistry
-
setLocalExecutorTransfer
-
incrementReportedErrorCount
public void incrementReportedErrorCount()
-