Package org.apache.storm.executor.bolt
Class BoltExecutor
java.lang.Object
org.apache.storm.executor.Executor
org.apache.storm.executor.bolt.BoltExecutor
- All Implemented Interfaces:
- Callable,- org.apache.storm.shade.org.jctools.queues.MessagePassingQueue.Consumer<Object>,- JCQueue.Consumer
- 
Field SummaryFields inherited from class org.apache.storm.executor.ExecutorackingEnabled, componentId, conf, credentials, executorId, executorTransfer, groupers, hasEventLoggers, hostname, idToTask, idToTaskBase, intervalToTaskToMetricToRegistry, isDebug, openOrPrepareWasCalled, pendingEmits, rand, receiveQueue, reportError, reportErrorDie, sampler, sharedExecutorData, stormActive, stormClusterState, stormComponentDebug, stormId, streamToComponentToGrouper, suicideFn, taskIds, taskToComponent, topoConf, type, workerData, workerReady, workerTopologyContext
- 
Constructor SummaryConstructorsConstructorDescriptionBoltExecutor(WorkerState workerData, List<Long> executorId, Map<String, String> credentials) 
- 
Method SummaryModifier and TypeMethodDescriptioncall()getStats()voidvoidtupleActionFn(int taskId, TupleImpl tuple) Methods inherited from class org.apache.storm.executor.Executoraccept, acceptTupleAction, execute, flush, getComponentId, getExecutorId, getExecutorTransfer, getIntervalToTaskToMetricToRegistry, getIsDebug, getOpenOrPrepareWasCalled, getPendingEmits, getReceiveQueue, getReportError, getSharedExecutorData, getStormClusterState, getStormComponentDebug, getStormId, getStreamToComponentToGrouper, getTaskIds, getTopoConf, getType, getWorkerData, getWorkerTopologyContext, incrementReportedErrorCount, metricsTick, mkExecutor, publishFlushTuple, reflectNewLoadMapping, samplerCheck, setLocalExecutorTransfer, setNeedToRefreshCreds, setupMetrics, setupTicks, updateExecCredsIfRequired
- 
Constructor Details- 
BoltExecutor
 
- 
- 
Method Details- 
getStats
- 
init- Throws:
- InterruptedException
 
- 
call- Throws:
- Exception
 
- 
tupleActionFn- Specified by:
- tupleActionFnin class- Executor
- Throws:
- Exception
 
 
-