import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
@Override
public void initialize(GraphState graphState,
  WorkerClientRequestProcessor<LongWritable, ARPVertexValue, NullWritable>
    workerClientRequestProcessor,
  GraphTaskManager<LongWritable, ARPVertexValue, NullWritable>
    graphTaskManager,
  WorkerGlobalCommUsage workerGlobalCommUsage, WorkerContext workerContext) {
  super.initialize(graphState, workerClientRequestProcessor, graphTaskManager,
    workerGlobalCommUsage, workerContext);
  this.k =
    getConf().getInt(NUMBER_OF_PARTITIONS, DEFAULT_NUMBER_OF_PARTITIONS);
  this.stableThreshold = getConf()
    .getInt(NUMBER_OF_STABLE_ITERATIONS, DEFAULT_NUMBER_OF_STABLE_ITERATIONS);
  this.capacityThreshold =
    getConf().getFloat(CAPACITY_THRESHOLD, DEFAULT_CAPACITY_THRESHOLD);
  this.totalPartitionCapacity = getTotalCapacity();
  this.isPartitioned = getConf()
    .getBoolean(ARPTextVertexInputFormat.PARTITIONED_INPUT,
      ARPTextVertexInputFormat.DEFAULT_PARTITIONED_INPUT);
  this.seed = getConf().getLong(SEED, DEFAULT_SEED);
  if (seed != 0) {
    random = new Random(seed);
  } else {
    random = new Random();
  }
}
 

import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
/**
 * Initialize, called by infrastructure before the superstep starts.
 * Shouldn't be called by user code.
 * 
 * @param graphState
 *            Graph state
 * @param workerClientRequestProcessor
 *            Processor for handling requests
 * @param graphTaskManager
 *            Graph-wide BSP Mapper for this Vertex
 * @param workerAggregatorUsage
 *            Worker aggregator usage
 * @param workerContext
 *            Worker context
 */
public void initialize(GraphState graphState,
		WorkerClientRequestProcessor<I, V, E> workerClientRequestProcessor,
		GraphTaskManager<I, V, E> graphTaskManager,
		WorkerAggregatorUsage workerAggregatorUsage,
		WorkerContext workerContext) {
	this.graphState = graphState;
	this.workerClientRequestProcessor = workerClientRequestProcessor;
	this.graphTaskManager = graphTaskManager;
	this.workerAggregatorUsage = workerAggregatorUsage;
	this.workerContext = workerContext;

	// Request the creation of the injector vertex right at the
	// initialization
	// addVertexRequest(INJECTOR_VERTEX_ID, INJECTOR_VERTEX_VALUE);
	// LOG.info("[PROMETHEUS] Injector Vertex created in initialization!");
}
 

import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public void initialize(GraphState graphState,
  WorkerClientRequestProcessor<LongWritable, DiffusionVertexValue,
    NullWritable> workerClientRequestProcessor,
  GraphTaskManager<LongWritable, DiffusionVertexValue, NullWritable>
    graphTaskManager,
  WorkerGlobalCommUsage workerGlobalCommUsage, WorkerContext workerContext) {
  this.k = getConf().getInt(NUMBER_OF_CLUSTERS, DEFAULT_NUMBER_OF_CLUSTERS);
  this.secondaryLoadFactor =
    getConf().getDouble(SECONDARY_LOAD_FACTOR, DEFAULT_SECONDARY_LOAD_FACTOR);
  super.initialize(graphState, workerClientRequestProcessor, graphTaskManager,
    workerGlobalCommUsage, workerContext);
}
 

import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
@Override
public void initialize(GraphState graphState,
  WorkerClientRequestProcessor<LongWritable, LPVertexValue, NullWritable>
    workerClientRequestProcessor,
  GraphTaskManager<LongWritable, LPVertexValue, NullWritable>
    graphTaskManager,
  WorkerGlobalCommUsage workerGlobalCommUsage, WorkerContext workerContext) {
  super.initialize(graphState, workerClientRequestProcessor, graphTaskManager,
    workerGlobalCommUsage, workerContext);
  this.stabilizationRounds = getConf()
    .getLong(STABILISATION_ROUNDS, DEFAULT_NUMBER_OF_STABILIZATION_ROUNDS);
}
 

import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
/**
 * Initialize, called by infrastructure before the superstep starts.
 * Shouldn't be called by user code.
 *
 * @param graphState Graph state
 * @param workerClientRequestProcessor Processor for handling requests
 * @param graphTaskManager Graph-wide BSP Mapper for this Vertex
 * @param workerAggregatorUsage Worker aggregator usage
 * @param workerContext Worker context
 */
@Override
public void initialize(
    GraphState graphState,
    WorkerClientRequestProcessor<I, V, E> workerClientRequestProcessor,
    GraphTaskManager<I, V, E> graphTaskManager,
    WorkerAggregatorUsage workerAggregatorUsage,
    WorkerContext workerContext) {
  this.graphState = graphState;
  this.workerClientRequestProcessor = workerClientRequestProcessor;
  this.graphTaskManager = graphTaskManager;
  this.workerAggregatorUsage = workerAggregatorUsage;
  this.workerContext = workerContext;
}
 

import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
public MockedEnvironment() {
    graphState = Mockito.mock(GraphState.class);
    context = Mockito.mock(Mapper.Context.class);
    conf = Mockito.mock(Configuration.class);
    workerClientRequestProcessor =
        Mockito.mock(WorkerClientRequestProcessor.class);
}
 

import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
/**
 * Constructor
 *
 * @param superstep Current superstep
 * @param numVertices Current graph-wide vertices
 * @param numEdges Current graph-wide edges
 * @param context Context
 * @param graphTaskManager GraphTaskManager for this compute node
 * @param workerClientRequestProcessor Handles all communication
 * @param workerAggregatorUsage Aggregator usage
 *
 */
public GraphState(
    long superstep, long numVertices,
    long numEdges, Mapper<?, ?, ?, ?>.Context context,
    GraphTaskManager<I, V, E, M> graphTaskManager,
    WorkerClientRequestProcessor<I, V, E, M> workerClientRequestProcessor,
    WorkerAggregatorUsage workerAggregatorUsage) {
  this.superstep = superstep;
  this.numVertices = numVertices;
  this.numEdges = numEdges;
  this.context = context;
  this.graphTaskManager = graphTaskManager;
  this.workerClientRequestProcessor = workerClientRequestProcessor;
  this.workerAggregatorUsage = workerAggregatorUsage;
}
 

import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
@Override
public void initialize(GraphState graphState, WorkerClientRequestProcessor<Text, DoubleWritable, Text> workerClientRequestProcessor, GraphTaskManager<Text, DoubleWritable, Text> graphTaskManager, WorkerGlobalCommUsage workerGlobalCommUsage, WorkerContext workerContext) {
    super.initialize(graphState, workerClientRequestProcessor, graphTaskManager, workerGlobalCommUsage, workerContext);
    DGALoggingUtil.setDGALogLevel(this.getConf());
}
 

import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
@Override
public void initialize(GraphState graphState, WorkerClientRequestProcessor<Text, LouvainNodeState, LongWritable> workerClientRequestProcessor, GraphTaskManager<Text, LouvainNodeState, LongWritable> graphTaskManager, WorkerGlobalCommUsage workerGlobalCommUsage, WorkerContext workerContext) {
    super.initialize(graphState, workerClientRequestProcessor, graphTaskManager, workerGlobalCommUsage, workerContext);
    DGALoggingUtil.setDGALogLevel(this.getConf());
}
 

import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
@Override
public void initialize(GraphState graphState, WorkerClientRequestProcessor<Text, Text, Text> workerClientRequestProcessor, GraphTaskManager<Text, Text, Text> graphTaskManager, WorkerGlobalCommUsage workerGlobalCommUsage, WorkerContext workerContext) {
    super.initialize(graphState, workerClientRequestProcessor, graphTaskManager, workerGlobalCommUsage, workerContext);
    DGALoggingUtil.setDGALogLevel(getConf());
}
 

import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
@Override
public void initialize(GraphState graphState, WorkerClientRequestProcessor<Text, VertexData, Text> workerClientRequestProcessor, GraphTaskManager<Text, VertexData, Text> graphTaskManager, WorkerGlobalCommUsage workerGlobalCommUsage, WorkerContext workerContext) {
    super.initialize(graphState, workerClientRequestProcessor, graphTaskManager, workerGlobalCommUsage, workerContext);
    DGALoggingUtil.setDGALogLevel(this.getConf());
}
 

import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
@Override
public void initialize(GraphState graphState, WorkerClientRequestProcessor<Text, Text, Text> workerClientRequestProcessor, GraphTaskManager<Text, Text, Text> graphTaskManager, WorkerGlobalCommUsage workerGlobalCommUsage, WorkerContext workerContext) {
    super.initialize(graphState, workerClientRequestProcessor, graphTaskManager, workerGlobalCommUsage, workerContext);
    DGALoggingUtil.setDGALogLevel(this.getConf());
}
 

import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
/** the injected worker communications */
public WorkerClientRequestProcessor getWorkerClientRequestProcessor() {
    return workerClientRequestProcessor;
}
 

import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
public WorkerClientRequestProcessor<I, V, E, M>
getWorkerClientRequestProcessor() {
  return workerClientRequestProcessor;
}
 

import org.apache.giraph.comm.WorkerClientRequestProcessor; //导入依赖的package包/类
/**
 * Initialize, called by infrastructure before the superstep starts.
 * Shouldn't be called by user code.
 *
 * @param graphState Graph state
 * @param workerClientRequestProcessor Processor for handling requests
 * @param graphTaskManager Graph-wide BSP Mapper for this Vertex
 * @param workerAggregatorUsage Worker aggregator usage
 * @param workerContext Worker context
 */
void initialize(GraphState graphState,
    WorkerClientRequestProcessor<I, V, E> workerClientRequestProcessor,
    GraphTaskManager<I, V, E> graphTaskManager,
    WorkerAggregatorUsage workerAggregatorUsage, WorkerContext workerContext);