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

Class LightBoltDeclarer

java.lang.Object

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

All Implemented Interfaces:

IBoltDeclarer

public class LightBoltDeclarer
extends Object
implements IBoltDeclarer

The LightBoltDeclarer is in charge of wiring the topology graph. Each bolt, when building the topology, upcalls its declarer method to specify to which (spout or bolt) component it subscribes to.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
LightBoltDeclarer(LightTopology topology, String boltComponentId, org.apache.storm.topology.IRichBolt bolt, int boltExecutors) Ctor.

Method Summary

Modifier and Type	Method and Description
void	allGrouping(String componentId, String streamEndOfBatch)
void	fieldsGrouping(String componentId, String streamId, org.apache.storm.tuple.Fields usedPartitionGroupingFields)
void	localOrShuffleGrouping(String sourceComponentId, String streamId)
void	shuffleGrouping(String componentId, String streamId)

Methods inherited from class java.lang.Object

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

Constructor Detail

LightBoltDeclarer

public LightBoltDeclarer(LightTopology topology,
                         String boltComponentId,
                         org.apache.storm.topology.IRichBolt bolt,
                         int boltExecutors)

Ctor.

Parameters:

topology - the owner light topology

boltComponentId - the bolt corresponding identifier, i.e. "mytenant_ltr_in"

bolt - the bolt object, created fro the bolt factory by the TopologyFactory.

boltExecutors - the number of executor

Method Detail

localOrShuffleGrouping

public void localOrShuffleGrouping(String sourceComponentId,
                                   String streamId)

Specified by:

localOrShuffleGrouping in interface IBoltDeclarer

shuffleGrouping

public void shuffleGrouping(String componentId,
                            String streamId)

Specified by:

shuffleGrouping in interface IBoltDeclarer

fieldsGrouping

public void fieldsGrouping(String componentId,
                           String streamId,
                           org.apache.storm.tuple.Fields usedPartitionGroupingFields)

Specified by:

fieldsGrouping in interface IBoltDeclarer

allGrouping

public void allGrouping(String componentId,
                        String streamEndOfBatch)

Specified by:

allGrouping in interface IBoltDeclarer