public class TridentBoltExecutor.CoordinatedOutputCollector extends Object implements IOutputCollector
Constructor and Description |
---|
CoordinatedOutputCollector(IOutputCollector delegate) |
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) |
public CoordinatedOutputCollector(IOutputCollector delegate)
public void setCurrBatch(TridentBoltExecutor.TrackedBatch batch)
public List<Integer> emit(String stream, Collection<Tuple> anchors, List<Object> tuple)
IOutputCollector
emit
in interface IOutputCollector
public void emitDirect(int task, String stream, Collection<Tuple> anchors, List<Object> tuple)
emitDirect
in interface IOutputCollector
public void ack(Tuple tuple)
ack
in interface IOutputCollector
public void fail(Tuple tuple)
fail
in interface IOutputCollector
public void reportError(Throwable error)
reportError
in interface IErrorReporter
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.