org.thales.punch.libraries.storm.core.topology.light

Class LightBoltOutputCollector

java.lang.Object

org.thales.punch.libraries.storm.core.topology.light.LightBoltOutputCollector

All Implemented Interfaces:

org.apache.storm.task.IErrorReporter, org.apache.storm.task.IOutputCollector

public class LightBoltOutputCollector
extends Object
implements org.apache.storm.task.IOutputCollector

Constructor Summary

Constructors

Constructor and Description
LightBoltOutputCollector(LightBoltRunner lightBolt)

Method Summary

Modifier and Type	Method and Description
void	ack(org.apache.storm.tuple.Tuple t) This method is thread safe.
List<Integer>	emit(String streamId, Collection<org.apache.storm.tuple.Tuple> anchors, List<Object> values) Emit a new tuple, anchored by another one.
void	emitDirect(int arg0, String arg1, Collection<org.apache.storm.tuple.Tuple> arg2, List<Object> arg3)
void	fail(org.apache.storm.tuple.Tuple t) This method is thread safe.
void	flush()
void	reportError(Throwable t)
void	resetTimeout(org.apache.storm.tuple.Tuple arg0)

Methods inherited from class java.lang.Object

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

Constructor Detail

LightBoltOutputCollector

public LightBoltOutputCollector(LightBoltRunner lightBolt)

Method Detail

reportError

public void reportError(Throwable t)

Specified by:

reportError in interface org.apache.storm.task.IErrorReporter

ack

public void ack(org.apache.storm.tuple.Tuple t)

This method is thread safe.

Specified by:

ack in interface org.apache.storm.task.IOutputCollector

emit

public List<Integer> emit(String streamId,
                          Collection<org.apache.storm.tuple.Tuple> anchors,
                          List<Object> values)

Emit a new tuple, anchored by another one. Dont be fooled by the Storm API, there is actually a single anchor tuple in the anchors argument

Specified by:

emit in interface org.apache.storm.task.IOutputCollector

emitDirect

public void emitDirect(int arg0,
                       String arg1,
                       Collection<org.apache.storm.tuple.Tuple> arg2,
                       List<Object> arg3)

Specified by:

emitDirect in interface org.apache.storm.task.IOutputCollector

fail

public void fail(org.apache.storm.tuple.Tuple t)

This method is thread safe.

Specified by:

fail in interface org.apache.storm.task.IOutputCollector

resetTimeout

public void resetTimeout(org.apache.storm.tuple.Tuple arg0)

Specified by:

resetTimeout in interface org.apache.storm.task.IOutputCollector

flush

public void flush()

Specified by:

flush in interface org.apache.storm.task.IOutputCollector