Package com.alibaba.graphscope.loader.impl

Class GraphDataBufferManagerImpl

java.lang.Object

com.alibaba.graphscope.loader.impl.GraphDataBufferManagerImpl

All Implemented Interfaces:

GraphDataBufferManager

public class GraphDataBufferManagerImpl
extends Object
implements GraphDataBufferManager

Constructor Summary

Constructors

Constructor	Description
GraphDataBufferManagerImpl(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 Summary

Modifier and Type	Method	Description
void	addEdge(int threadId, org.apache.hadoop.io.WritableComparable srcId, org.apache.hadoop.io.WritableComparable dstId, org.apache.hadoop.io.Writable value)
void	addEdges(int threadId, org.apache.hadoop.io.Writable id, Iterable<org.apache.giraph.edge.Edge> edges)
void	addVertex(int threadId, org.apache.hadoop.io.Writable id, org.apache.hadoop.io.Writable value)
void	finishAdding()
void	reserveNumEdges(int length)
void	reserveNumVertices(int length)	resize for std vector

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GraphDataBufferManagerImpl

public GraphDataBufferManagerImpl(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