#include <dual_csr.h>

Inheritance diagram for gs::DualCsr< std::string_view >:

Collaboration diagram for gs::DualCsr< std::string_view >:

[legend]

Public Member Functions
	DualCsr (EdgeStrategy oe_strategy, EdgeStrategy ie_strategy, uint16_t width)

	~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 std::string_view &data)

void	BatchPutEdge (vid_t src, vid_t dst, const std::string &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< std::string_view > *	in_csr_

TypedCsrBase< std::string_view > *	out_csr_

std::atomic< size_t >	column_idx_

StringColumn	column_

Constructor & Destructor Documentation

◆ DualCsr()

gs::DualCsr< std::string_view >::DualCsr	(	EdgeStrategy	oe_strategy,
		EdgeStrategy	ie_strategy,
		uint16_t	width
	)

inline

◆ ~DualCsr()

gs::DualCsr< std::string_view >::~DualCsr ( )

inline

Member Function Documentation

◆ BatchInit()

void gs::DualCsr< std::string_view >::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()

void gs::DualCsr< std::string_view >::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() [1/2]

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

inline

◆ BatchPutEdge() [2/2]

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

inline

◆ Close()

void gs::DualCsr< std::string_view >::Close ( )

inlineoverridevirtual

Implements gs::DualCsrBase.

◆ Dump()

void gs::DualCsr< std::string_view >::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]

const CsrBase* gs::DualCsr< std::string_view >::GetInCsr ( ) const

inlineoverridevirtual

Implements gs::DualCsrBase.

◆ GetInCsr() [2/2]

CsrBase* gs::DualCsr< std::string_view >::GetInCsr ( )

inlineoverridevirtual

Implements gs::DualCsrBase.

◆ GetOutCsr() [1/2]

const CsrBase* gs::DualCsr< std::string_view >::GetOutCsr ( ) const

inlineoverridevirtual

Implements gs::DualCsrBase.

◆ GetOutCsr() [2/2]

CsrBase* gs::DualCsr< std::string_view >::GetOutCsr ( )

inlineoverridevirtual

Implements gs::DualCsrBase.

◆ IngestEdge()

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

inlineoverridevirtual

Implements gs::DualCsrBase.

◆ Open()

void gs::DualCsr< std::string_view >::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()

void gs::DualCsr< std::string_view >::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()

void gs::DualCsr< std::string_view >::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()

void gs::DualCsr< std::string_view >::SortByEdgeData ( timestamp_t ts )

inlineoverridevirtual

Implements gs::DualCsrBase.

◆ UpdateEdge()

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

inlineoverridevirtual

Implements gs::DualCsrBase.

Member Data Documentation

◆ column_

StringColumn gs::DualCsr< std::string_view >::column_

private

◆ column_idx_

std::atomic<size_t> gs::DualCsr< std::string_view >::column_idx_

private

◆ in_csr_

TypedCsrBase<std::string_view>* gs::DualCsr< std::string_view >::in_csr_

private

◆ out_csr_

TypedCsrBase<std::string_view>* gs::DualCsr< std::string_view >::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

Public Member Functions

Private Attributes

Constructor & Destructor Documentation

◆ DualCsr()

◆ ~DualCsr()

Member Function Documentation

◆ BatchInit()

◆ BatchInitInMemory()

◆ BatchPutEdge() [1/2]

◆ BatchPutEdge() [2/2]

◆ Close()

◆ Dump()

◆ GetInCsr() [1/2]

◆ GetInCsr() [2/2]

◆ GetOutCsr() [1/2]

◆ GetOutCsr() [2/2]

◆ IngestEdge()

◆ Open()

◆ OpenInMemory()

◆ OpenWithHugepages()

◆ SortByEdgeData()

◆ UpdateEdge()

Member Data Documentation

◆ column_

◆ column_idx_

◆ in_csr_

◆ out_csr_