Package | Description |
---|---|
org.apache.storm.executor.spout |
Modifier and Type | Method and Description |
---|---|
void |
SpoutExecutor.ackSpoutMsg(SpoutExecutor executor,
Task taskData,
Long timeDelta,
TupleInfo tupleInfo) |
void |
SpoutExecutor.failSpoutMsg(SpoutExecutor executor,
Task taskData,
Long timeDelta,
TupleInfo tupleInfo,
String reason) |
Constructor and Description |
---|
SpoutOutputCollectorImpl(ISpout spout,
SpoutExecutor executor,
Task taskData,
MutableLong emittedCount,
boolean hasAckers,
Random random,
Boolean isEventLoggers,
Boolean isDebug,
RotatingMap<Long,TupleInfo> pending) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.