backtype.storm.state

Class SynchronizeOutputCollector

java.lang.Object

backtype.storm.state.SynchronizeOutputCollector

All Implemented Interfaces:

ISynchronizeOutputCollector

Direct Known Subclasses:

StateSpoutOutputCollector

public class SynchronizeOutputCollector
extends Object
implements ISynchronizeOutputCollector

Constructor Summary

Constructors

Constructor and Description
SynchronizeOutputCollector()

Method Summary

Modifier and Type	Method and 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 Detail

SynchronizeOutputCollector

public SynchronizeOutputCollector()

Method Detail

add

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

Specified by:

add in interface ISynchronizeOutputCollector