backtype.storm.state
Class SynchronizeOutputCollector

java.lang.Object
  extended by backtype.storm.state.SynchronizeOutputCollector
All Implemented Interfaces:
ISynchronizeOutputCollector
Direct Known Subclasses:
StateSpoutOutputCollector

public class SynchronizeOutputCollector
extends java.lang.Object
implements ISynchronizeOutputCollector


Constructor Summary
SynchronizeOutputCollector()
           
 
Method Summary
 void add(int streamId, java.lang.Object id, java.util.List<java.lang.Object> tuple)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SynchronizeOutputCollector

public SynchronizeOutputCollector()
Method Detail

add

public void add(int streamId,
                java.lang.Object id,
                java.util.List<java.lang.Object> tuple)
Specified by:
add in interface ISynchronizeOutputCollector