Package org.apache.storm.spout
package org.apache.storm.spout
-
ClassDescriptionEmits checkpoint tuples which is used to save the state of the
IStatefulComponent
across the topology.Captures the current state of the transaction inCheckpointSpout
.ISpout is the core interface for implementing spouts.Methods are not expected to be thread safe.This output collector exposes the API for emitting tuples from anIRichSpout
.