public class BoltExecutor extends 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 and Description |
|---|
BoltExecutor(WorkerState workerData,
List<Long> executorId,
Map<String,String> credentials) |
| Modifier and Type | Method and Description |
|---|---|
Callable<Long> |
call() |
BoltExecutorStats |
getStats() |
void |
init(ArrayList<Task> idToTask,
int idToTaskBase) |
void |
tupleActionFn(int taskId,
TupleImpl tuple) |
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, updateExecCredsIfRequiredpublic BoltExecutorStats getStats()
public void init(ArrayList<Task> idToTask, int idToTaskBase) throws InterruptedException
InterruptedExceptionpublic void tupleActionFn(int taskId,
TupleImpl tuple)
throws Exception
tupleActionFn in class ExecutorExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.