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