storm.trident.topology
Class TridentBoltExecutor.CoordinatedOutputCollector

java.lang.Object
  storm.trident.topology.TridentBoltExecutor.CoordinatedOutputCollector

All Implemented Interfaces:

IOutputCollector

Enclosing class:

TridentBoltExecutor

public class TridentBoltExecutor.CoordinatedOutputCollector
extends java.lang.Object
implements IOutputCollector

Constructor Summary

TridentBoltExecutor.CoordinatedOutputCollector(IOutputCollector delegate)

Method Summary

void	ack(Tuple tuple)
java.util.List<java.lang.Integer>	emit(java.lang.String stream, java.util.Collection<Tuple> anchors, java.util.List<java.lang.Object> tuple) Returns the task ids that received the tuples.
void	emitDirect(int task, java.lang.String stream, java.util.Collection<Tuple> anchors, java.util.List<java.lang.Object> tuple)
void	fail(Tuple tuple)
void	reportError(java.lang.Throwable error)
void	setCurrBatch(TridentBoltExecutor.TrackedBatch batch)

Methods inherited from class java.lang.Object

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

Constructor Detail

TridentBoltExecutor.CoordinatedOutputCollector

public TridentBoltExecutor.CoordinatedOutputCollector(IOutputCollector delegate)

Method Detail

setCurrBatch

public void setCurrBatch(TridentBoltExecutor.TrackedBatch batch)

emit

public java.util.List<java.lang.Integer> emit(java.lang.String stream,
                                              java.util.Collection<Tuple> anchors,
                                              java.util.List<java.lang.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,
                       java.lang.String stream,
                       java.util.Collection<Tuple> anchors,
                       java.util.List<java.lang.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

reportError

public void reportError(java.lang.Throwable error)

Specified by:

reportError in interface IOutputCollector