public abstract static class GraphReintegration.PlainGraphReintegration extends org.apache.giraph.graph.AbstractComputation<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable,LayoutMessage,LayoutMessage>
Modifier and Type | Field and Description |
---|---|
protected long |
added |
protected float |
aperture |
protected static double |
DEGREE_TO_RADIANS_CONSTANT |
protected boolean |
isRadiusDynamic |
protected float |
k |
protected float |
padding |
protected float |
paddingDefault |
protected static double |
RADIANS_TO_DEGREE_CONSTANT |
protected float |
radius |
Constructor and Description |
---|
GraphReintegration.PlainGraphReintegration() |
Modifier and Type | Method and Description |
---|---|
protected float[][] |
computeOneDegreeVerticesCoordinates(org.apache.giraph.graph.Vertex<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> vertex,
int quantity,
float slopeAngle,
float slopeStart) |
protected float[][] |
placeVerticesInCone(org.apache.giraph.graph.Vertex<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> vertex,
int size,
java.lang.Iterable<LayoutMessage> itl) |
void |
preSuperstep() |
protected void |
reconstructGraph(float[][] verticesToPlace,
org.apache.giraph.graph.Vertex<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> vertex) |
protected void |
reconstructGraphKeepingIterator(float[][] verticesToPlace,
org.apache.giraph.graph.Vertex<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> vertex,
java.util.Iterator<org.apache.hadoop.io.LongWritable> woundIterator) |
protected float[][] |
vertexPlacer(long quantity,
float sector,
float start,
float[] myCoords,
float effectiveRadius) |
addEdgeRequest, addVertexRequest, addVertexRequest, compute, getContext, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerContext, initialize, postSuperstep, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, sendMessageToMultipleEdges
aggregate, getAggregatedValue, getBroadcast, reduce, setWorkerGlobalCommUsage
getConf, setConf
protected long added
protected float aperture
protected static final double DEGREE_TO_RADIANS_CONSTANT
protected boolean isRadiusDynamic
protected float k
protected float padding
protected float paddingDefault
protected static final double RADIANS_TO_DEGREE_CONSTANT
protected float radius
public GraphReintegration.PlainGraphReintegration()
protected float[][] computeOneDegreeVerticesCoordinates(org.apache.giraph.graph.Vertex<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> vertex, int quantity, float slopeAngle, float slopeStart) throws java.io.IOException
java.io.IOException
protected float[][] placeVerticesInCone(org.apache.giraph.graph.Vertex<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> vertex, int size, java.lang.Iterable<LayoutMessage> itl) throws java.io.IOException
java.io.IOException
public void preSuperstep()
preSuperstep
in interface org.apache.giraph.graph.Computation<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable,LayoutMessage,LayoutMessage>
preSuperstep
in class org.apache.giraph.graph.AbstractComputation<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable,LayoutMessage,LayoutMessage>
protected void reconstructGraph(float[][] verticesToPlace, org.apache.giraph.graph.Vertex<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> vertex) throws java.io.IOException
java.io.IOException
protected void reconstructGraphKeepingIterator(float[][] verticesToPlace, org.apache.giraph.graph.Vertex<PartitionedLongWritable,CoordinateWritable,org.apache.hadoop.io.NullWritable> vertex, java.util.Iterator<org.apache.hadoop.io.LongWritable> woundIterator) throws java.io.IOException
java.io.IOException
protected float[][] vertexPlacer(long quantity, float sector, float start, float[] myCoords, float effectiveRadius) throws java.io.IOException
java.io.IOException