import org.apache.giraph.aggregators.DoubleSumAggregator; //导入依赖的package包/类
@Override
public void initialize() throws InstantiationException,
        IllegalAccessException {
  registerPersistentAggregator(
          TrustRankComputation.SUM_OF_LOGS, DoubleSumAggregator.class);
  registerPersistentAggregator(
          TrustRankComputation.SUM_OF_DEVS, DoubleSumAggregator.class);
  registerPersistentAggregator(
          TrustRankComputation.AVG_OF_LOGS, DoubleSumAggregator.class);
  registerPersistentAggregator(
          TrustRankComputation.STDEV, DoubleSumAggregator.class);

  registerPersistentAggregator(
          TrustRankComputation.NUM_TRUSTED, IntSumAggregator.class);
  registerPersistentAggregator(
          TrustRankComputation.TRUSTED_VERTICES, TextAppendAggregator.class);


  registerAggregator(TrustRankComputation.DANGLING_AGG,
          DoubleSumAggregator.class);
}
 

import org.apache.giraph.aggregators.DoubleSumAggregator; //导入依赖的package包/类
@Override
public void initialize() throws InstantiationException, IllegalAccessException {
    this.registerAggregator(LouvainComputation.CHANGE_AGG, LongSumAggregator.class);
    this.registerPersistentAggregator(LouvainComputation.TOTAL_EDGE_WEIGHT_AGG, LongSumAggregator.class);
    this.registerPersistentAggregator(LouvainComputation.ACTUAL_Q_AGG, DoubleSumAggregator.class);
    DGALoggingUtil.setDGALogLevel(this.getConf());
}
 

import org.apache.giraph.aggregators.DoubleSumAggregator; //导入依赖的package包/类
@Override
public void initialize() throws InstantiationException, IllegalAccessException {
        this.registerAggregator(LouvainVertex.CHANGE_AGG, LongSumAggregator.class);
        this.registerPersistentAggregator(LouvainVertex.TOTAL_EDGE_WEIGHT_AGG, LongSumAggregator.class);
        //for (int i =0; i < LouvainVertex.getNumQAggregators(getConf()); i++){
        	this.registerPersistentAggregator(LouvainVertex.ACTUAL_Q_AGG, DoubleSumAggregator.class);
        //}
        
}
 

import org.apache.giraph.aggregators.DoubleSumAggregator; //导入依赖的package包/类
@Override
public void initialize() throws InstantiationException,
  IllegalAccessException {
  registerPersistentAggregator(
          LinkRankComputation.SUM_OF_LOGS, DoubleSumAggregator.class);
  registerPersistentAggregator(
          LinkRankComputation.SUM_OF_DEVS, DoubleSumAggregator.class);
  registerPersistentAggregator(
          LinkRankComputation.AVG_OF_LOGS, DoubleSumAggregator.class);
  registerPersistentAggregator(
          LinkRankComputation.STDEV, DoubleSumAggregator.class);

  registerAggregator(LinkRankComputation.DANGLING_AGG,
          DoubleSumAggregator.class);
}
 

import org.apache.giraph.aggregators.DoubleSumAggregator; //导入依赖的package包/类
@Override
public void initialize() throws InstantiationException,
    IllegalAccessException {
  registerAggregator(RandomWalkComputation.NUM_DANGLING_VERTICES,
      LongSumAggregator.class);
  registerAggregator(RandomWalkComputation.CUMULATIVE_DANGLING_PROBABILITY,
      DoubleSumAggregator.class);
  registerAggregator(RandomWalkComputation.CUMULATIVE_PROBABILITY,
      DoubleSumAggregator.class);
  registerAggregator(RandomWalkComputation.L1_NORM_OF_PROBABILITY_DIFFERENCE,
      DoubleSumAggregator.class);
}
 

import org.apache.giraph.aggregators.DoubleSumAggregator; //导入依赖的package包/类
@Override
public void initialize() throws InstantiationException,
    IllegalAccessException {
  registerAggregator(RandomWalkVertex.NUM_DANGLING_VERTICES,
      LongSumAggregator.class);
  registerAggregator(RandomWalkVertex.CUMULATIVE_DANGLING_PROBABILITY,
      DoubleSumAggregator.class);
  registerAggregator(RandomWalkVertex.CUMULATIVE_PROBABILITY,
      DoubleSumAggregator.class);
  registerAggregator(RandomWalkVertex.L1_NORM_OF_PROBABILITY_DIFFERENCE,
      DoubleSumAggregator.class);
}