Package org.apache.storm.state

Class SynchronizeOutputCollector

java.lang.Object

org.apache.storm.state.SynchronizeOutputCollector

All Implemented Interfaces:

ISynchronizeOutputCollector

Direct Known Subclasses:

StateSpoutOutputCollector

public class SynchronizeOutputCollector
extends Object
implements ISynchronizeOutputCollector

Constructor Summary

Constructors

Constructor	Description
SynchronizeOutputCollector()

Method Summary

Modifier and Type	Method	Description
void	add(int streamId, Object id, List<Object> tuple)

Methods inherited from class java.lang.Object

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

Constructor Details

SynchronizeOutputCollector

public SynchronizeOutputCollector()

Method Details

add

public void add(int streamId,
 Object id,
 List<Object> tuple)

Specified by:

add in interface ISynchronizeOutputCollector