Inheritance diagram for grape::BasicEFileFragmentLoader< FRAG_T >:
Public Member Functions | |
| BasicEFileFragmentLoader (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::unique_ptr< HashPartitioner< oid_t > > | partitioner_ |
| std::vector< ShuffleOut< internal_oid_t, internal_oid_t, edata_t > > | edges_to_frag_ |
| std::thread | edge_recv_thread_ |
| bool | recv_thread_running_ |
| std::vector< ShuffleBufferTuple< internal_oid_t, internal_oid_t, edata_t > > | got_edges_ |
| int | concurrency_ |
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 |
