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, updateExecCredsIfRequired
public BoltExecutorStats getStats()
public void init(ArrayList<Task> idToTask, int idToTaskBase) throws InterruptedException
InterruptedException
public void tupleActionFn(int taskId, TupleImpl tuple) throws Exception
tupleActionFn
in class Executor
Exception
Copyright © 2023 The Apache Software Foundation. All rights reserved.