org.apache.storm.coordination

Class CoordinatedBolt.CoordinatedOutputCollector

java.lang.Object

org.apache.storm.coordination.CoordinatedBolt.CoordinatedOutputCollector

All Implemented Interfaces:

IErrorReporter, IOutputCollector

Enclosing class:

CoordinatedBolt

public class CoordinatedBolt.CoordinatedOutputCollector
extends Object
implements IOutputCollector

Constructor Summary

Constructors

Constructor and Description
CoordinatedOutputCollector(IOutputCollector delegate)

Method Summary

Modifier and Type	Method and Description
void	ack(Tuple tuple)
List<Integer>	emit(String stream, Collection<Tuple> anchors, List<Object> tuple) Returns the task ids that received the tuples.
void	emitDirect(int task, String stream, Collection<Tuple> anchors, List<Object> tuple)
void	fail(Tuple tuple)
void	flush()
void	reportError(Throwable error)
void	resetTimeout(Tuple tuple)

Methods inherited from class java.lang.Object

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

Constructor Detail

CoordinatedOutputCollector

public CoordinatedOutputCollector(IOutputCollector delegate)

Method Detail

emit

public List<Integer> emit(String stream,
                          Collection<Tuple> anchors,
                          List<Object> tuple)

Description copied from interface: IOutputCollector

Returns the task ids that received the tuples.

Specified by:

emit in interface IOutputCollector

emitDirect

public void emitDirect(int task,
                       String stream,
                       Collection<Tuple> anchors,
                       List<Object> tuple)

Specified by:

emitDirect in interface IOutputCollector

ack

public void ack(Tuple tuple)

Specified by:

ack in interface IOutputCollector

fail

public void fail(Tuple tuple)

Specified by:

fail in interface IOutputCollector

flush

public void flush()

Specified by:

flush in interface IOutputCollector

resetTimeout

public void resetTimeout(Tuple tuple)

Specified by:

resetTimeout in interface IOutputCollector

reportError

public void reportError(Throwable error)

Specified by:

reportError in interface IErrorReporter