public class StormBoltDeclarer extends Object implements IBoltDeclarer
Constructor and Description |
---|
StormBoltDeclarer(org.apache.storm.topology.BoltDeclarer declarer)
Ctor
|
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) |
public StormBoltDeclarer(org.apache.storm.topology.BoltDeclarer declarer)
declarer
- the storm boltdeclarerpublic void localOrShuffleGrouping(String componentId, String streamId)
localOrShuffleGrouping
in interface IBoltDeclarer
public void shuffleGrouping(String componentId, String streamId)
shuffleGrouping
in interface IBoltDeclarer
public void fieldsGrouping(String componentId, String streamId, org.apache.storm.tuple.Fields usedPartitionGroupingFields)
fieldsGrouping
in interface IBoltDeclarer
public void allGrouping(String id, String streamEndOfBatch)
allGrouping
in interface IBoltDeclarer
Copyright © 2023. All rights reserved.