GraphLab: Distributed Graph-Parallel API
2.1
|
Ingress object assigning edges using randoming hash function. More...
#include <graphlab/graph/ingress/distributed_random_ingress.hpp>
Public Types | |
typedef distributed_graph < VertexData, EdgeData > | graph_type |
typedef VertexData | vertex_data_type |
The type of the vertex data stored in the graph. | |
typedef EdgeData | edge_data_type |
The type of the edge data stored in the graph. | |
typedef distributed_ingress_base < VertexData, EdgeData > | base_type |
typedef graph_type::vertex_record | vertex_record |
typedef graph_type::mirror_type | mirror_type |
Public Member Functions | |
distributed_random_ingress (distributed_control &dc, graph_type &graph) | |
void | add_edge (vertex_id_type source, vertex_id_type target, const EdgeData &edata) |
virtual void | add_vertex (vertex_id_type vid, const VertexData &vdata) |
Add an vertex to the ingress object. | |
virtual void | finalize () |
Finalize completes the local graph data structure and the vertex record information. | |
void | exchange_global_info () |
Public Attributes | |
dc_dist_object < distributed_ingress_base > | rpc |
The rpc interface for this object. | |
graph_type & | graph |
The underlying distributed graph object that is being loaded. | |
buffered_exchange < vertex_buffer_record > | vertex_exchange |
buffered_exchange < edge_buffer_record > | edge_exchange |
ingress_edge_decision < VertexData, EdgeData > | edge_decision |
Ingress decision object for computing the edge destination. |
Protected Member Functions | |
procid_t | vertex_to_proc (const vertex_id_type vid) const |
Returns the random hashed pid of a vertex. |
Ingress object assigning edges using randoming hash function.
Definition at line 44 of file distributed_random_ingress.hpp.
|
inlinevirtual |
Add an edge to the ingress object using random assignment.
Implements graphlab::idistributed_ingress< VertexData, EdgeData >.
Definition at line 64 of file distributed_random_ingress.hpp.