@NotThreadSafe public class WorkerProgressStats extends Object
Modifier and Type | Field and Description |
---|---|
protected boolean |
computationDone
Whether all compute supersteps are done
|
protected long |
currentSuperstep
Superstep which worker is executing, Long.MAX_VALUE if it's output
|
protected int |
edgeInputSplitsLoaded
How many edge input splits were loaded until now
|
protected long |
edgesLoaded
How many edges were loaded
|
protected double |
freeMemoryFraction
Fraction of memory that's free
|
protected double |
freeMemoryMB
Free memory
|
protected boolean |
loadingEdgesDone
Whether worker finished loading edges until now
|
protected boolean |
loadingVerticesDone
Whether worker finished loading vertices
|
protected int |
lowestGraphPercentageInMemory
Lowest percentage of graph in memory throughout the execution so far
|
protected int |
partitionsComputed
How many partitions were computed in current superstep until now
|
protected int |
partitionsStored
How many partitions were stored until now
|
protected int |
partitionsToCompute
How many partitions are there to compute in current superstep
|
protected int |
partitionsToStore
How many partitions are there to store
|
protected boolean |
storingDone
Whether worker finished storing data
|
protected int |
taskId
Id of the mapper
|
protected int |
vertexInputSplitsLoaded
How many vertex input splits were loaded until now
|
protected long |
verticesComputed
How many vertices were computed in current superstep until now
|
protected long |
verticesLoaded
How many vertices were loaded until now
|
protected long |
verticesStored
How many vertices were stored until now
|
protected long |
verticesToCompute
How many vertices are there to compute in current superstep
|
protected long |
verticesToStore
How many vertices are there to store
|
Constructor and Description |
---|
WorkerProgressStats() |
Modifier and Type | Method and Description |
---|---|
boolean |
isComputeSuperstep() |
boolean |
isInputSuperstep() |
boolean |
isOutputSuperstep() |
protected long currentSuperstep
protected long verticesLoaded
protected int vertexInputSplitsLoaded
protected boolean loadingVerticesDone
protected long edgesLoaded
protected int edgeInputSplitsLoaded
protected boolean loadingEdgesDone
protected long verticesToCompute
protected long verticesComputed
protected int partitionsToCompute
protected int partitionsComputed
protected boolean computationDone
protected long verticesToStore
protected long verticesStored
protected int partitionsToStore
protected int partitionsStored
protected boolean storingDone
protected int taskId
protected double freeMemoryMB
protected double freeMemoryFraction
protected int lowestGraphPercentageInMemory
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.