org.thales.punch.libraries.storm.core.topology.light

Class LightOutputDeclarer

java.lang.Object

org.thales.punch.libraries.storm.core.topology.light.LightOutputDeclarer

All Implemented Interfaces:

org.apache.storm.topology.OutputFieldsDeclarer

public class LightOutputDeclarer
extends Object
implements org.apache.storm.topology.OutputFieldsDeclarer

Constructor Summary

Constructors

Constructor and Description
LightOutputDeclarer(LightComponent c)
LightOutputDeclarer(LightTopology topology, String componentId)

Method Summary

Modifier and Type	Method and Description
void	declare(boolean direct, org.apache.storm.tuple.Fields fields)
void	declare(org.apache.storm.tuple.Fields fields)
void	declareStream(String streamId, boolean direct, org.apache.storm.tuple.Fields fields)
void	declareStream(String streamId, org.apache.storm.tuple.Fields fields)

Methods inherited from class java.lang.Object

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

Constructor Detail

LightOutputDeclarer

public LightOutputDeclarer(LightTopology topology,
                           String componentId)

LightOutputDeclarer

public LightOutputDeclarer(LightComponent c)

Method Detail

declare

public void declare(org.apache.storm.tuple.Fields fields)

Specified by:

declare in interface org.apache.storm.topology.OutputFieldsDeclarer

declare

public void declare(boolean direct,
                    org.apache.storm.tuple.Fields fields)

Specified by:

declare in interface org.apache.storm.topology.OutputFieldsDeclarer

declareStream

public void declareStream(String streamId,
                          org.apache.storm.tuple.Fields fields)

Specified by:

declareStream in interface org.apache.storm.topology.OutputFieldsDeclarer

declareStream

public void declareStream(String streamId,
                          boolean direct,
                          org.apache.storm.tuple.Fields fields)

Specified by:

declareStream in interface org.apache.storm.topology.OutputFieldsDeclarer