public interface IBoltDeclarer
Implementations provided by apache storm or punchplatform light storm compatible runtime.
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) |
Copyright © 2023. All rights reserved.