Package org.apache.storm.executor.spout
Class SpoutExecutor
java.lang.Object
org.apache.storm.executor.Executor
org.apache.storm.executor.spout.SpoutExecutor
- 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 SummaryConstructorsConstructorDescriptionSpoutExecutor(WorkerState workerData, List<Long> executorId, Map<String, String> credentials) 
- 
Method SummaryModifier and TypeMethodDescriptionprotected voidacceptTupleAction(int taskId, TupleImpl tuple) voidackSpoutMsg(SpoutExecutor executor, Task taskData, Long timeDelta, TupleInfo tupleInfo) call()voidfailSpoutMsg(SpoutExecutor executor, Task taskData, Long timeDelta, TupleInfo tupleInfo, String reason) intgetStats()longvoidvoidtupleActionFn(int taskId, TupleImpl tuple) Methods inherited from class org.apache.storm.executor.Executoraccept, 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- 
SpoutExecutor
 
- 
- 
Method Details- 
getStats
- 
init- Throws:
- InterruptedException
 
- 
call- Throws:
- Exception
 
- 
acceptTupleAction- Overrides:
- acceptTupleActionin class- Executor
 
- 
tupleActionFn- Specified by:
- tupleActionFnin class- Executor
- Throws:
- Exception
 
- 
ackSpoutMsg
- 
failSpoutMsgpublic void failSpoutMsg(SpoutExecutor executor, Task taskData, Long timeDelta, TupleInfo tupleInfo, String reason) 
- 
getSpoutRecvqCheckSkipCountpublic int getSpoutRecvqCheckSkipCount()
- 
getThreadIdpublic long getThreadId()
 
-