|
libgrape-lite
A C++ library for parallel graph processing
|
Public Member Functions | |
| BasicFragmentLoader (const CommSpec &comm_spec, const LoadGraphSpec &spec) | |
| void | AddVertex (const oid_t &id, const vdata_t &data) override |
| void | ConstructVertices () override |
| void | AddEdge (const oid_t &src, const oid_t &dst, const edata_t &data) override |
| void | ConstructFragment (std::shared_ptr< fragment_t > &fragment) override |
Public Member Functions inherited from grape::BasicFragmentLoaderBase< FRAG_T > | |
| BasicFragmentLoaderBase (const CommSpec &comm_spec, const LoadGraphSpec &spec) | |
Private Types | |
| using | fragment_t = FRAG_T |
| using | oid_t = typename fragment_t::oid_t |
| using | internal_oid_t = typename InternalOID< oid_t >::type |
| using | vid_t = typename fragment_t::vid_t |
| using | vdata_t = typename fragment_t::vdata_t |
| using | edata_t = typename fragment_t::edata_t |
Private Member Functions | |
| void | edgeRecvRoutine () |
Private Attributes | |
| std::vector< oid_t > | vertices_ |
| std::vector< vdata_t > | vdata_ |
| std::vector< internal::Vertex< vid_t, vdata_t > > | processed_vertices_ |
| std::unique_ptr< VertexMap< oid_t, vid_t > > | vertex_map_ |
| std::vector< ShuffleOut< vid_t, vid_t, edata_t > > | edges_to_frag_ |
| std::thread | edge_recv_thread_ |
| bool | recv_thread_running_ |
| std::vector< ShuffleBufferTuple< vid_t, vid_t, edata_t > > | got_edges_ |
| std::vector< vid_t > | src_gid_list_ |
| std::vector< vid_t > | dst_gid_list_ |
| std::vector< edata_t > | edata_ |
Additional Inherited Members | |
Protected Member Functions inherited from grape::BasicFragmentLoaderBase< FRAG_T > | |
| void | InitOuterVertexData (std::shared_ptr< fragment_t > fragment) |
| void | ShuffleVertex (const std::vector< oid_t > &added_vertices_id, std::vector< std::vector< oid_t > > &local_vertices_id, const IPartitioner< oid_t > &partitioner) |
| void | ShuffleVertexData (const std::vector< oid_t > &added_vertices_id, const std::vector< vdata_t > &added_vertices_data, std::vector< std::vector< oid_t > > &local_vertices_id, std::vector< std::vector< vdata_t > > &local_vertices_data, const IPartitioner< oid_t > &partitioner) |
Protected Attributes inherited from grape::BasicFragmentLoaderBase< FRAG_T > | |
| CommSpec | comm_spec_ |
| LoadGraphSpec | spec_ |
| IdParser< vid_t > | id_parser_ |
Static Protected Attributes inherited from grape::BasicFragmentLoaderBase< FRAG_T > | |
| static constexpr int | vertex_tag = 5 |
| static constexpr int | edge_tag = 6 |
|
inlineoverridevirtual |
Implements grape::BasicFragmentLoaderBase< FRAG_T >.
|
inlineoverridevirtual |
Implements grape::BasicFragmentLoaderBase< FRAG_T >.
|
inlineoverridevirtual |
Implements grape::BasicFragmentLoaderBase< FRAG_T >.
|
inlineoverridevirtual |
Implements grape::BasicFragmentLoaderBase< FRAG_T >.