import storm.trident.state.map.MapCombinerAggStateUpdater; //导入依赖的package包/类
public TridentState persistentAggregate(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields) {
    return aggregate(inputFields, agg, functionFields)
            .partitionPersist(spec,
                    TridentUtils.fieldsUnion(_groupFields, functionFields),
                    new MapCombinerAggStateUpdater(agg, _groupFields, functionFields),
                    TridentUtils.fieldsConcat(_groupFields, functionFields)); 
}
 

import storm.trident.state.map.MapCombinerAggStateUpdater; //导入依赖的package包/类
public TridentState persistentAggregate(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields) {
    return aggregate(inputFields, agg, functionFields).partitionPersist(spec, TridentUtils.fieldsUnion(_groupFields, functionFields),
            new MapCombinerAggStateUpdater(agg, _groupFields, functionFields), TridentUtils.fieldsConcat(_groupFields, functionFields));
}