public class LightBoltOutputCollector extends Object implements org.apache.storm.task.IOutputCollector
Constructor and Description |
---|
LightBoltOutputCollector(LightBoltRunner lightBolt) |
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) |
public LightBoltOutputCollector(LightBoltRunner lightBolt)
public void reportError(Throwable t)
reportError
in interface org.apache.storm.task.IErrorReporter
public void ack(org.apache.storm.tuple.Tuple t)
ack
in interface org.apache.storm.task.IOutputCollector
public List<Integer> emit(String streamId, Collection<org.apache.storm.tuple.Tuple> anchors, List<Object> values)
emit
in interface org.apache.storm.task.IOutputCollector
public void emitDirect(int arg0, String arg1, Collection<org.apache.storm.tuple.Tuple> arg2, List<Object> arg3)
emitDirect
in interface org.apache.storm.task.IOutputCollector
public void fail(org.apache.storm.tuple.Tuple t)
fail
in interface org.apache.storm.task.IOutputCollector
public void resetTimeout(org.apache.storm.tuple.Tuple arg0)
resetTimeout
in interface org.apache.storm.task.IOutputCollector
public void flush()
flush
in interface org.apache.storm.task.IOutputCollector
Copyright © 2023. All rights reserved.