blob: 31a2a7f8e1e002f073e3dea5173c0d47487b8235 [file] [log] [blame]
package backtype.storm.state;
import java.util.List;
public interface ISynchronizeOutputCollector {
void add(int streamId, Object id, List<Object> tuple);
}