Package org.apache.storm.hooks.info

Class EmitInfo

java.lang.Object

org.apache.storm.hooks.info.EmitInfo

public class EmitInfo
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
Collection<Integer>	outTasks
String	stream
int	taskId
List<Object>	values

Constructor Summary

Constructors

Constructor	Description
EmitInfo(List<Object> values, String stream, int taskId, Collection<Integer> outTasks)

Method Summary

Modifier and Type	Method	Description
void	applyOn(TopologyContext topologyContext)

Methods inherited from class java.lang.Object

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

Field Detail

values

public List<Object> values

stream

public String stream

taskId

public int taskId

outTasks

public Collection<Integer> outTasks

Constructor Detail

EmitInfo

public EmitInfo(List<Object> values,
                String stream,
                int taskId,
                Collection<Integer> outTasks)

Method Detail

applyOn

public void applyOn(TopologyContext topologyContext)