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 Summary
Fields inherited from class org.apache.storm.executor.Executor
ackingEnabled, 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 Summary
ConstructorsConstructorDescriptionSpoutExecutor(WorkerState workerData, List<Long> executorId, Map<String, String> credentials) -
Method Summary
Modifier 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.Executor
accept, 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 classExecutor
-
tupleActionFn
- Specified by:
tupleActionFnin classExecutor- Throws:
Exception
-
ackSpoutMsg
-
failSpoutMsg
public void failSpoutMsg(SpoutExecutor executor, Task taskData, Long timeDelta, TupleInfo tupleInfo, String reason) -
getSpoutRecvqCheckSkipCount
public int getSpoutRecvqCheckSkipCount() -
getThreadId
public long getThreadId()
-