backtype.storm.state

Class StateSpoutOutputCollector

java.lang.Object

backtype.storm.state.SynchronizeOutputCollector

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