storm.trident.topology

Class TridentBoltExecutor.CoordinatedOutputCollector

java.lang.Object

storm.trident.topology.TridentBoltExecutor.CoordinatedOutputCollector

All Implemented Interfaces:

IErrorReporter, IOutputCollector

Enclosing class:

TridentBoltExecutor

public class TridentBoltExecutor.CoordinatedOutputCollector
extends Object
implements IOutputCollector

Constructor Summary

Constructors

Constructor and Description
TridentBoltExecutor.CoordinatedOutputCollector(IOutputCollector delegate)

Method Summary

Methods

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	reportError(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 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

reportError

public void reportError(Throwable error)

Specified by:

reportError in interface IErrorReporter