Constructor Detail

• GraphDataBufferManangerImpl

  public GraphDataBufferManangerImpl​(int workerId,
                                     int threadNum,
                                     FFIByteVecVector vidBuffers,
                                     FFIByteVecVector vertexDataBuffers,
                                     FFIByteVecVector edgeSrcIdBuffers,
                                     FFIByteVecVector edgeDstIdBuffers,
                                     FFIByteVecVector edgeDataBuffers,
                                     FFIIntVecVector vidOffsets,
                                     FFIIntVecVector vertexDataOffsets,
                                     FFIIntVecVector edgeSrcIdOffsets,
                                     FFIIntVecVector edgeDstIdOffsets,
                                     FFIIntVecVector edgeDataOffsets)

Method Detail

• addVertex

  public void addVertex​(int threadId,
                        org.apache.hadoop.io.Writable id,
                        org.apache.hadoop.io.Writable value)
                 throws IOException

  Specified by:

  addVertex in interface GraphDataBufferManager

  Throws:

  IOException

• addEdges

  public void addEdges​(int threadId,
                       org.apache.hadoop.io.Writable id,
                       Iterable<org.apache.giraph.edge.Edge> edges)
                throws IOException

  Specified by:

  addEdges in interface GraphDataBufferManager

  Throws:

  IOException

• addEdge

  public void addEdge​(int threadId,
                      org.apache.hadoop.io.WritableComparable srcId,
                      org.apache.hadoop.io.WritableComparable dstId,
                      org.apache.hadoop.io.Writable value)
               throws IOException

  Specified by:

  addEdge in interface GraphDataBufferManager

  Throws:

  IOException

• reserveNumVertices

  public void reserveNumVertices​(int length)

  resize for std vector

  Specified by:

  reserveNumVertices in interface GraphDataBufferManager

  Parameters:

  length - number of vertices.

• reserveNumEdges

  public void reserveNumEdges​(int length)

  Specified by:

  reserveNumEdges in interface GraphDataBufferManager

• finishAdding

  public void finishAdding()

  Specified by:

  finishAdding in interface GraphDataBufferManager