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

Class StormBoltDeclarer

java.lang.Object

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

All Implemented Interfaces:

IBoltDeclarer

public class StormBoltDeclarer
extends Object
implements IBoltDeclarer

Default bolt declarer.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
StormBoltDeclarer(org.apache.storm.topology.BoltDeclarer declarer) Ctor

Method Summary

Modifier and Type	Method and Description
void	allGrouping(String id, String streamEndOfBatch)
void	fieldsGrouping(String componentId, String streamId, org.apache.storm.tuple.Fields usedPartitionGroupingFields)
void	localOrShuffleGrouping(String componentId, 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

StormBoltDeclarer

public StormBoltDeclarer(org.apache.storm.topology.BoltDeclarer declarer)

Ctor

Parameters:

declarer - the storm boltdeclarer

Method Detail

localOrShuffleGrouping

public void localOrShuffleGrouping(String componentId,
                                   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 id,
                        String streamEndOfBatch)

Specified by:

allGrouping in interface IBoltDeclarer