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
ConstructorDescriptionSpoutExecutor
(WorkerState workerData, List<Long> executorId, Map<String, String> credentials) -
Method Summary
Modifier and TypeMethodDescriptionvoid
ackSpoutMsg
(SpoutExecutor executor, Task taskData, Long timeDelta, TupleInfo tupleInfo) call()
void
failSpoutMsg
(SpoutExecutor executor, Task taskData, Long timeDelta, TupleInfo tupleInfo, String reason) int
getStats()
long
void
void
tupleActionFn
(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
-
tupleActionFn
- Specified by:
tupleActionFn
in 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()
-