org.apache.storm.state

Class StateSpoutOutputCollector

java.lang.Object

org.apache.storm.state.SynchronizeOutputCollector

org.apache.storm.state.StateSpoutOutputCollector

All Implemented Interfaces:

IStateSpoutOutputCollector, ISynchronizeOutputCollector

public class StateSpoutOutputCollector
extends SynchronizeOutputCollector
implements IStateSpoutOutputCollector

Constructor Summary

Constructors

Constructor and Description
StateSpoutOutputCollector()

Method Summary

Modifier and Type	Method and Description
void	remove(int streamId, Object id)

Methods inherited from class org.apache.storm.state.SynchronizeOutputCollector

add

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.storm.state.ISynchronizeOutputCollector

add

Constructor Detail

StateSpoutOutputCollector

public StateSpoutOutputCollector()

Method Detail

remove

public void remove(int streamId,
                   Object id)

Specified by:

remove in interface IStateSpoutOutputCollector