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`

public class BoltExecutor extends Executor

- ## 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

  Constructors
  Constructor
  Description
  `BoltExecutor(WorkerState workerData, List<Long> executorId, Map<String,String> credentials)`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `Callable<Long>`
  `call()`
  `BoltExecutorStats`
  `getStats()`
  `void`
  `init(ArrayList<Task> idToTask, int idToTaskBase)`
  `void`
  `tupleActionFn(int taskId, TupleImpl tuple)`

  ### Methods inherited from class org.apache.storm.executor.Executor

  `accept, 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`

  ### Methods inherited from class java.lang.Object

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- ## Constructor Details

  - ### BoltExecutor

    public BoltExecutor(WorkerState workerData, List<Long> executorId, Map<String,String> credentials)

- ## Method Details

  - ### getStats

    public BoltExecutorStats getStats()
    Specified by:
      `getStats` in class `Executor`

  - ### init

    public void init(ArrayList<Task> idToTask, int idToTaskBase) throws InterruptedException
    Throws:
      `InterruptedException`

  - ### call

    public Callable<Long> call() throws Exception
    Throws:
      `Exception`

  - ### tupleActionFn

    public void tupleActionFn(int taskId, TupleImpl tuple) throws Exception
    Specified by:
      `tupleActionFn` in class `Executor`
    Throws:
      `Exception`