gs::DualCsr< EDATA_T > Class Template Reference

#include <dual_csr.h>

Inheritance diagram for gs::DualCsr< EDATA_T >:

Collaboration diagram for gs::DualCsr< EDATA_T >:

Public Member Functions
	DualCsr (EdgeStrategy oe_strategy, EdgeStrategy ie_strategy, bool oe_mutable, bool ie_mutable)
	~DualCsr ()
void	BatchInit (const std::string &oe_name, const std::string &ie_name, const std::string &edata_name, const std::string &work_dir, const std::vector< int > &oe_degree, const std::vector< int > &ie_degree) override
void	BatchInitInMemory (const std::string &edata_name, const std::string &work_dir, const std::vector< int > &oe_degree, const std::vector< int > &ie_degree) override
void	Open (const std::string &oe_name, const std::string &ie_name, const std::string &edata_name, const std::string &snapshot_dir, const std::string &work_dir) override
void	OpenInMemory (const std::string &oe_name, const std::string &ie_name, const std::string &edata_name, const std::string &snapshot_dir, size_t src_vertex_cap, size_t dst_vertex_cap) override
void	OpenWithHugepages (const std::string &oe_name, const std::string &ie_name, const std::string &edata_name, const std::string &snapshot_dir, size_t src_vertex_cap, size_t dst_vertex_cap) override
void	Dump (const std::string &oe_name, const std::string &ie_name, const std::string &edata_name, const std::string &new_snapshot_dir) override
CsrBase *	GetInCsr () override
CsrBase *	GetOutCsr () override
const CsrBase *	GetInCsr () const override
const CsrBase *	GetOutCsr () const override
void	IngestEdge (vid_t src, vid_t dst, grape::OutArchive &oarc, timestamp_t ts, Allocator &alloc) override
void	SortByEdgeData (timestamp_t ts) override
void	UpdateEdge (vid_t src, vid_t dst, const Any &data, timestamp_t ts, Allocator &alloc) override
void	BatchPutEdge (vid_t src, vid_t dst, const EDATA_T &data)
void	Close () override
Public Member Functions inherited from gs::DualCsrBase
	DualCsrBase ()=default
virtual	~DualCsrBase ()=default
void	Resize (vid_t src_vertex_num, vid_t dst_vertex_num)
void	Warmup (int thread_num)
size_t	EdgeNum () const

Private Attributes
TypedCsrBase< EDATA_T > *	in_csr_
TypedCsrBase< EDATA_T > *	out_csr_

Constructor & Destructor Documentation

DualCsr()

template<typename EDATA_T >

gs::DualCsr< EDATA_T >::DualCsr ( EdgeStrategy  oe_strategy, EdgeStrategy  ie_strategy, bool  oe_mutable, bool  ie_mutable  )

inline

~DualCsr()

template<typename EDATA_T >

gs::DualCsr< EDATA_T >::~DualCsr ( )

inline

Member Function Documentation

BatchInit()

template<typename EDATA_T >

void gs::DualCsr< EDATA_T >::BatchInit ( const std::string &  oe_name, const std::string &  ie_name, const std::string &  edata_name, const std::string &  work_dir, const std::vector< int > &  oe_degree, const std::vector< int > &  ie_degree  )

inlineoverridevirtual

Implements gs::DualCsrBase.

BatchInitInMemory()

template<typename EDATA_T >

void gs::DualCsr< EDATA_T >::BatchInitInMemory ( const std::string &  edata_name, const std::string &  work_dir, const std::vector< int > &  oe_degree, const std::vector< int > &  ie_degree  )

inlineoverridevirtual

Implements gs::DualCsrBase.

BatchPutEdge()

template<typename EDATA_T >

void gs::DualCsr< EDATA_T >::BatchPutEdge ( vid_t  src, vid_t  dst, const EDATA_T &  data  )

inline

Close()

template<typename EDATA_T >

void gs::DualCsr< EDATA_T >::Close ( )

inlineoverridevirtual

Implements gs::DualCsrBase.

Dump()

template<typename EDATA_T >

void gs::DualCsr< EDATA_T >::Dump ( const std::string &  oe_name, const std::string &  ie_name, const std::string &  edata_name, const std::string &  new_snapshot_dir  )

inlineoverridevirtual

Implements gs::DualCsrBase.

GetInCsr() [1/2]

template<typename EDATA_T >

const CsrBase* gs::DualCsr< EDATA_T >::GetInCsr ( ) const

inlineoverridevirtual

Implements gs::DualCsrBase.

GetInCsr() [2/2]

template<typename EDATA_T >

CsrBase* gs::DualCsr< EDATA_T >::GetInCsr ( )

inlineoverridevirtual

Implements gs::DualCsrBase.

GetOutCsr() [1/2]

template<typename EDATA_T >

const CsrBase* gs::DualCsr< EDATA_T >::GetOutCsr ( ) const

inlineoverridevirtual

Implements gs::DualCsrBase.

GetOutCsr() [2/2]

template<typename EDATA_T >

CsrBase* gs::DualCsr< EDATA_T >::GetOutCsr ( )

inlineoverridevirtual

Implements gs::DualCsrBase.

IngestEdge()

template<typename EDATA_T >

void gs::DualCsr< EDATA_T >::IngestEdge ( vid_t  src, vid_t  dst, grape::OutArchive &  oarc, timestamp_t  ts, Allocator &  alloc  )

inlineoverridevirtual

Implements gs::DualCsrBase.

Open()

template<typename EDATA_T >

void gs::DualCsr< EDATA_T >::Open ( const std::string &  oe_name, const std::string &  ie_name, const std::string &  edata_name, const std::string &  snapshot_dir, const std::string &  work_dir  )

inlineoverridevirtual

Implements gs::DualCsrBase.

OpenInMemory()

template<typename EDATA_T >

void gs::DualCsr< EDATA_T >::OpenInMemory ( const std::string &  oe_name, const std::string &  ie_name, const std::string &  edata_name, const std::string &  snapshot_dir, size_t  src_vertex_cap, size_t  dst_vertex_cap  )

inlineoverridevirtual

Implements gs::DualCsrBase.

OpenWithHugepages()

template<typename EDATA_T >

void gs::DualCsr< EDATA_T >::OpenWithHugepages ( const std::string &  oe_name, const std::string &  ie_name, const std::string &  edata_name, const std::string &  snapshot_dir, size_t  src_vertex_cap, size_t  dst_vertex_cap  )

inlineoverridevirtual

Implements gs::DualCsrBase.

SortByEdgeData()

template<typename EDATA_T >

void gs::DualCsr< EDATA_T >::SortByEdgeData ( timestamp_t  ts )

inlineoverridevirtual

Implements gs::DualCsrBase.

UpdateEdge()

template<typename EDATA_T >

void gs::DualCsr< EDATA_T >::UpdateEdge ( vid_t  src, vid_t  dst, const Any &  data, timestamp_t  ts, Allocator &  alloc  )

inlineoverridevirtual

Implements gs::DualCsrBase.

Member Data Documentation

in_csr_

template<typename EDATA_T >

TypedCsrBase<EDATA_T>* gs::DualCsr< EDATA_T >::in_csr_

private

out_csr_

template<typename EDATA_T >

TypedCsrBase<EDATA_T>* gs::DualCsr< EDATA_T >::out_csr_

private

---

The documentation for this class was generated from the following file:

• /home/runner/work/GraphScope/GraphScope/flex/storages/rt_mutable_graph/dual_csr.h