#include <mutable_csr.h>

Inheritance diagram for gs::MutableCsr< EDATA_T >:

[legend]

Collaboration diagram for gs::MutableCsr< EDATA_T >:

[legend]

Public Types
using	nbr_t = MutableNbr< EDATA_T >

using	adjlist_t = MutableAdjlist< EDATA_T >

using	slice_t = MutableNbrSlice< EDATA_T >

using	mut_slice_t = MutableNbrSliceMut< EDATA_T >

Public Types inherited from gs::TypedMutableCsrBase< EDATA_T >
using	slice_t = MutableNbrSlice< EDATA_T >

Public Member Functions
	MutableCsr ()

	~MutableCsr ()

size_t	batch_init (const std::string &name, const std::string &work_dir, const std::vector< int > &degree, double reserve_ratio) override

size_t	batch_init_in_memory (const std::vector< int > &degree, double reserve_ratio) override

void	batch_put_edge (vid_t src, vid_t dst, const EDATA_T &data, timestamp_t ts) override

void	batch_sort_by_edge_data (timestamp_t ts) override

timestamp_t	unsorted_since () const override

void	open (const std::string &name, const std::string &snapshot_dir, const std::string &work_dir) override

void	open_in_memory (const std::string &prefix, size_t v_cap) override

void	open_with_hugepages (const std::string &prefix, size_t v_cap) override

void	dump (const std::string &name, const std::string &new_snapshot_dir) override

void	warmup (int thread_num) const override

void	resize (vid_t vnum) override

size_t	size () const override

size_t	edge_num () const override

std::shared_ptr< CsrConstEdgeIterBase >	edge_iter (vid_t v) const override

CsrConstEdgeIterBase *	edge_iter_raw (vid_t v) const override

std::shared_ptr< CsrEdgeIterBase >	edge_iter_mut (vid_t v) override

void	put_edge (vid_t src, vid_t dst, const EDATA_T &data, timestamp_t ts, Allocator &alloc) override

slice_t	get_edges (vid_t v) const override

mut_slice_t	get_edges_mut (vid_t i)

void	close () override

Public Member Functions inherited from gs::CsrBase
	CsrBase ()=default

virtual	~CsrBase ()=default

Private Member Functions
void	load_meta (const std::string &prefix)

void	dump_meta (const std::string &prefix) const

Private Attributes
grape::SpinLock *	locks_

mmap_array< adjlist_t >	adj_lists_

mmap_array< nbr_t >	nbr_list_

timestamp_t	unsorted_since_

Member Typedef Documentation

◆ adjlist_t

template<typename EDATA_T >

using gs::MutableCsr< EDATA_T >::adjlist_t = MutableAdjlist<EDATA_T>

◆ mut_slice_t

template<typename EDATA_T >

using gs::MutableCsr< EDATA_T >::mut_slice_t = MutableNbrSliceMut<EDATA_T>

◆ nbr_t

template<typename EDATA_T >

using gs::MutableCsr< EDATA_T >::nbr_t = MutableNbr<EDATA_T>

◆ slice_t

template<typename EDATA_T >

using gs::MutableCsr< EDATA_T >::slice_t = MutableNbrSlice<EDATA_T>

Constructor & Destructor Documentation

◆ MutableCsr()

template<typename EDATA_T >

gs::MutableCsr< EDATA_T >::MutableCsr ( )

inline

◆ ~MutableCsr()

template<typename EDATA_T >

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

inline

Member Function Documentation

◆ batch_init()

template<typename EDATA_T >

size_t gs::MutableCsr< EDATA_T >::batch_init	(	const std::string &	name,
		const std::string &	work_dir,
		const std::vector< int > &	degree,
		double	reserve_ratio
	)

inlineoverridevirtual

Implements gs::CsrBase.

◆ batch_init_in_memory()

template<typename EDATA_T >

size_t gs::MutableCsr< EDATA_T >::batch_init_in_memory	(	const std::vector< int > &	degree,
		double	reserve_ratio
	)

inlineoverridevirtual

Implements gs::CsrBase.

◆ batch_put_edge()

template<typename EDATA_T >

void gs::MutableCsr< EDATA_T >::batch_put_edge	(	vid_t	src,
		vid_t	dst,
		const EDATA_T &	data,
		timestamp_t	ts
	)

inlineoverridevirtual

Implements gs::TypedCsrBase< EDATA_T >.

◆ batch_sort_by_edge_data()

template<typename EDATA_T >

void gs::MutableCsr< EDATA_T >::batch_sort_by_edge_data ( timestamp_t ts )

inlineoverridevirtual

Reimplemented from gs::CsrBase.

◆ close()

template<typename EDATA_T >

void gs::MutableCsr< EDATA_T >::close ( )

inlineoverridevirtual

Implements gs::CsrBase.

◆ dump()

template<typename EDATA_T >

void gs::MutableCsr< EDATA_T >::dump	(	const std::string &	name,
		const std::string &	new_snapshot_dir
	)

inlineoverridevirtual

Implements gs::CsrBase.

◆ dump_meta()

template<typename EDATA_T >

void gs::MutableCsr< EDATA_T >::dump_meta ( const std::string & prefix ) const

inlineprivate

◆ edge_iter()

template<typename EDATA_T >

std::shared_ptr<CsrConstEdgeIterBase> gs::MutableCsr< EDATA_T >::edge_iter ( vid_t v ) const

inlineoverridevirtual

Implements gs::CsrBase.

◆ edge_iter_mut()

template<typename EDATA_T >

std::shared_ptr<CsrEdgeIterBase> gs::MutableCsr< EDATA_T >::edge_iter_mut ( vid_t v )

inlineoverridevirtual

Implements gs::CsrBase.

◆ edge_iter_raw()

template<typename EDATA_T >

CsrConstEdgeIterBase* gs::MutableCsr< EDATA_T >::edge_iter_raw ( vid_t v ) const

inlineoverridevirtual

Implements gs::CsrBase.

◆ edge_num()

template<typename EDATA_T >

size_t gs::MutableCsr< EDATA_T >::edge_num ( ) const

inlineoverridevirtual

Implements gs::CsrBase.

◆ get_edges()

template<typename EDATA_T >

slice_t gs::MutableCsr< EDATA_T >::get_edges ( vid_t v ) const

inlineoverridevirtual

Implements gs::TypedMutableCsrBase< EDATA_T >.

◆ get_edges_mut()

template<typename EDATA_T >

mut_slice_t gs::MutableCsr< EDATA_T >::get_edges_mut ( vid_t i )

inline

◆ load_meta()

template<typename EDATA_T >

void gs::MutableCsr< EDATA_T >::load_meta ( const std::string & prefix )

inlineprivate

◆ open()

template<typename EDATA_T >

void gs::MutableCsr< EDATA_T >::open	(	const std::string &	name,
		const std::string &	snapshot_dir,
		const std::string &	work_dir
	)

inlineoverridevirtual

Implements gs::CsrBase.

◆ open_in_memory()

template<typename EDATA_T >

void gs::MutableCsr< EDATA_T >::open_in_memory	(	const std::string &	prefix,
		size_t	v_cap
	)

inlineoverridevirtual

Implements gs::CsrBase.

◆ open_with_hugepages()

template<typename EDATA_T >

void gs::MutableCsr< EDATA_T >::open_with_hugepages	(	const std::string &	prefix,
		size_t	v_cap
	)

inlineoverridevirtual

Reimplemented from gs::CsrBase.

◆ put_edge()

template<typename EDATA_T >

void gs::MutableCsr< EDATA_T >::put_edge	(	vid_t	src,
		vid_t	dst,
		const EDATA_T &	data,
		timestamp_t	ts,
		Allocator &	alloc
	)

inlineoverridevirtual

Implements gs::TypedCsrBase< EDATA_T >.

◆ resize()

template<typename EDATA_T >

void gs::MutableCsr< EDATA_T >::resize ( vid_t vnum )

inlineoverridevirtual

Implements gs::CsrBase.

◆ size()

template<typename EDATA_T >

size_t gs::MutableCsr< EDATA_T >::size ( ) const

inlineoverridevirtual

Implements gs::CsrBase.

◆ unsorted_since()

template<typename EDATA_T >

timestamp_t gs::MutableCsr< EDATA_T >::unsorted_since ( ) const

inlineoverridevirtual

Reimplemented from gs::CsrBase.

◆ warmup()

template<typename EDATA_T >

void gs::MutableCsr< EDATA_T >::warmup ( int thread_num ) const

inlineoverridevirtual

Implements gs::CsrBase.

Member Data Documentation

◆ adj_lists_

template<typename EDATA_T >

mmap_array<adjlist_t> gs::MutableCsr< EDATA_T >::adj_lists_

private

◆ locks_

template<typename EDATA_T >

grape::SpinLock* gs::MutableCsr< EDATA_T >::locks_

private

◆ nbr_list_

template<typename EDATA_T >

mmap_array<nbr_t> gs::MutableCsr< EDATA_T >::nbr_list_

private

◆ unsorted_since_

template<typename EDATA_T >

timestamp_t gs::MutableCsr< EDATA_T >::unsorted_since_

private

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

/home/runner/work/GraphScope/GraphScope/flex/storages/rt_mutable_graph/csr/mutable_csr.h

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Member Typedef Documentation

◆ adjlist_t

◆ mut_slice_t

◆ nbr_t

◆ slice_t

Constructor & Destructor Documentation

◆ MutableCsr()

◆ ~MutableCsr()

Member Function Documentation

◆ batch_init()

◆ batch_init_in_memory()

◆ batch_put_edge()

◆ batch_sort_by_edge_data()

◆ close()

◆ dump()

◆ dump_meta()

◆ edge_iter()

◆ edge_iter_mut()

◆ edge_iter_raw()

◆ edge_num()

◆ get_edges()

◆ get_edges_mut()

◆ load_meta()

◆ open()

◆ open_in_memory()

◆ open_with_hugepages()

◆ put_edge()

◆ resize()

◆ size()

◆ unsorted_since()

◆ warmup()

Member Data Documentation

◆ adj_lists_

◆ locks_

◆ nbr_list_

◆ unsorted_since_