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 SummaryFieldsModifier and TypeFieldDescriptionprotected final booleanprotected final Stringprotected ExecutorTransferprotected final List<LoadAwareCustomStreamGrouping>protected final Booleanprotected Stringprotected intprotected final Booleanprotected final AtomicBooleanprotected final org.apache.storm.shade.org.jctools.queues.MpscChunkedArrayQueue<AddressedTuple>protected final Randomprotected final JCQueueprotected final IReportErrorprotected final ReportErrorAndDieprotected final BooleanSupplierprotected final HashMapprotected final AtomicBooleanprotected final IStormClusterStateprotected final AtomicReference<Map<String,DebugOptions>> protected final Stringprotected final Map<String,Map<String, LoadAwareCustomStreamGrouping>> protected final Runnableprotected final Stringprotected final WorkerStateprotected final CountDownLatchprotected final WorkerTopologyContext
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidprotected voidacceptTupleAction(int taskId, TupleImpl tuple) execute()separated from mkExecutor in order to replace executor transfer in executor data for testing.voidflush()abstract CommonStatsgetStats()getType()voidvoidmetricsTick(Task task, TupleImpl tuple) static ExecutormkExecutor(WorkerState workerState, List<Long> executorId, Map<String, String> credentials) booleanvoidreflectNewLoadMapping(LoadMapping loadMapping) booleanvoidsetLocalExecutorTransfer(ExecutorTransfer executorTransfer) voidprotected voidprotected voidsetupTicks(boolean isSpout) abstract voidtupleActionFn(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
- 
ackingEnabledprotected final boolean ackingEnabled
- 
pendingEmitsprotected final org.apache.storm.shade.org.jctools.queues.MpscChunkedArrayQueue<AddressedTuple> pendingEmits
- 
executorTransfer
- 
idToTask
- 
idToTaskBaseprotected int idToTaskBase
- 
hostname
 
- 
- 
Constructor Details- 
Executor
 
- 
- 
Method Details- 
mkExecutor
- 
getPendingEmits
- 
executeseparated from mkExecutor in order to replace executor transfer in executor data for testing.- Throws:
- Exception
 
- 
tupleActionFn- Throws:
- Exception
 
- 
accept- Specified by:
- acceptin interface- JCQueue.Consumer
- Specified by:
- acceptin interface- org.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>
 
- 
acceptTupleAction
- 
setNeedToRefreshCredspublic void setNeedToRefreshCreds()
- 
updateExecCredsIfRequiredprotected void updateExecCredsIfRequired()
- 
flushpublic void flush()- Specified by:
- flushin interface- JCQueue.Consumer
 
- 
metricsTick
- 
setupMetricsprotected void setupMetrics()
- 
setupTicksprotected void setupTicks(boolean isSpout) 
- 
reflectNewLoadMapping
- 
publishFlushTuplepublic boolean publishFlushTuple()
- 
getExecutorId
- 
getTaskIds
- 
getComponentId
- 
getOpenOrPrepareWasCalled
- 
getTopoConf
- 
getStormId
- 
getStats
- 
getType
- 
getIsDebug
- 
getExecutorTransfer
- 
getReportError
- 
getWorkerTopologyContext
- 
samplerCheckpublic boolean samplerCheck()
- 
getStormComponentDebug
- 
getReceiveQueue
- 
getStormClusterState
- 
getWorkerData
- 
getStreamToComponentToGrouper
- 
getIntervalToTaskToMetricToRegistry
- 
setLocalExecutorTransfer
- 
incrementReportedErrorCountpublic void incrementReportedErrorCount()
 
-