import org.apache.storm.grouping.CustomStreamGrouping; //导入依赖的package包/类
private CustomStreamGrouping buildCustomStreamGrouping(ObjectDefinition objectDefinition,
                                                       EcoExecutionContext executionContext,
                                                       ObjectBuilder objectBuilder)
    throws ClassNotFoundException,
    IllegalAccessException, InstantiationException, NoSuchFieldException,
    InvocationTargetException {
  Object grouping = objectBuilder.buildObject(objectDefinition, executionContext);
  return (CustomStreamGrouping) grouping;
}
 

import org.apache.storm.grouping.CustomStreamGrouping; //导入依赖的package包/类
@Override
public BoltDeclarer customGrouping(String componentId, CustomStreamGrouping grouping) {
  return customGrouping(componentId, Utils.DEFAULT_STREAM_ID, grouping);
}
 

import org.apache.storm.grouping.CustomStreamGrouping; //导入依赖的package包/类
T customGrouping(String componentId, CustomStreamGrouping grouping);