import storm.trident.fluent.ChainedAggregatorDeclarer; //导入依赖的package包/类
public TridentState persistentAggregate(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields) {
    projectionValidation(inputFields);
    // replaces normal aggregation here with a global grouping because it needs to be consistent across batches 
    return new ChainedAggregatorDeclarer(this, new GlobalAggScheme())
            .aggregate(inputFields, agg, functionFields)
            .chainEnd()
           .partitionPersist(spec, functionFields, new CombinerAggStateUpdater(agg), functionFields);
}
 

import storm.trident.fluent.ChainedAggregatorDeclarer; //导入依赖的package包/类
public ChainedAggregatorDeclarer chainedAgg() {
    return new ChainedAggregatorDeclarer(this, new BatchGlobalAggScheme());
}
 

import storm.trident.fluent.ChainedAggregatorDeclarer; //导入依赖的package包/类
public TridentState persistentAggregate(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields) {
    projectionValidation(inputFields);
    // replaces normal aggregation here with a global grouping because it needs to be consistent across batches
    return new ChainedAggregatorDeclarer(this, new GlobalAggScheme()).aggregate(inputFields, agg, functionFields).chainEnd()
            .partitionPersist(spec, functionFields, new CombinerAggStateUpdater(agg), functionFields);
}