public class LightSpoutOutputCollector extends Object implements org.apache.storm.spout.ISpoutOutputCollector
Each spout instance has its own collector.
Constructor and Description |
---|
LightSpoutOutputCollector(LightSpout lightSpout) |
Modifier and Type | Method and Description |
---|---|
long |
decPendingCount() |
List<Integer> |
emit(String streamId,
List<Object> values,
Object messageId) |
void |
emitDirect(int taskId,
String arg1,
List<Object> arg2,
Object arg3) |
void |
flush() |
long |
getPendingCount() |
void |
reportError(Throwable t) |
public LightSpoutOutputCollector(LightSpout lightSpout)
public void reportError(Throwable t)
reportError
in interface org.apache.storm.task.IErrorReporter
public List<Integer> emit(String streamId, List<Object> values, Object messageId)
emit
in interface org.apache.storm.spout.ISpoutOutputCollector
public void emitDirect(int taskId, String arg1, List<Object> arg2, Object arg3)
emitDirect
in interface org.apache.storm.spout.ISpoutOutputCollector
public long getPendingCount()
getPendingCount
in interface org.apache.storm.spout.ISpoutOutputCollector
public long decPendingCount()
public void flush()
flush
in interface org.apache.storm.spout.ISpoutOutputCollector
Copyright © 2023. All rights reserved.