The arrow chunk reader for edge property group chunks. More...

#include <chunk_reader.h>

Public Types
using	range_t = std::pair< IdType, IdType >

Public Member Functions
	AdjListPropertyArrowChunkReader (const std::shared_ptr< EdgeInfo > &edge_info, const std::shared_ptr< PropertyGroup > &property_group, AdjListType adj_list_type, const std::string prefix, const util::FilterOptions &options={})
	Initialize the AdjListPropertyArrowChunkReader. More...

	AdjListPropertyArrowChunkReader (const AdjListPropertyArrowChunkReader &other)
	Copy constructor.

Status	seek_src (IdType id)
	Sets chunk position indicator for reader by source vertex id. More...

Status	seek_dst (IdType id)
	Sets chunk position indicator for reader by destination vertex id. More...

Status	seek (IdType offset)
	Sets chunk position indicator for reader by edge index. More...

Result< std::shared_ptr< arrow::Table > >	GetChunk ()
	Return the current chunk of chunk position indicator as arrow::Table, if the chunk is empty, return nullptr.

Status	next_chunk ()
	Sets chunk position indicator to next chunk. More...

Status	seek_chunk_index (IdType vertex_chunk_index, IdType chunk_index=0)
	Sets chunk position to the specific vertex chunk and edge chunk. More...

void	Filter (util::Filter filter=nullptr)
	Apply the row filter to the table. No parameter call Filter() will clear the filter. More...

void	Select (util::ColumnNames column_names=std::nullopt)
	Apply the projection to the table to be read. No parameter call Select() will clear the projection. More...

Static Public Member Functions
static Result< std::shared_ptr< AdjListPropertyArrowChunkReader > >	Make (const std::shared_ptr< EdgeInfo > &edge_info, const std::shared_ptr< PropertyGroup > &property_group, AdjListType adj_list_type, const std::string &prefix, const util::FilterOptions &options={})
	Create an AdjListPropertyArrowChunkReader instance from edge info. More...

static Result< std::shared_ptr< AdjListPropertyArrowChunkReader > >	Make (const std::shared_ptr< GraphInfo > &graph_info, const std::string &src_type, const std::string &edge_type, const std::string &dst_type, const std::shared_ptr< PropertyGroup > &property_group, AdjListType adj_list_type, const util::FilterOptions &options={})
	Create an AdjListPropertyArrowChunkReader instance from graph info and property group. More...

static Result< std::shared_ptr< AdjListPropertyArrowChunkReader > >	Make (const std::shared_ptr< GraphInfo > &graph_info, const std::string &src_type, const std::string &edge_type, const std::string &dst_type, const std::string &property_name, AdjListType adj_list_type, const util::FilterOptions &options={})
	Create an AdjListPropertyArrowChunkReader instance from graph info and property name. More...

Detailed Description

The arrow chunk reader for edge property group chunks.

Definition at line 474 of file chunk_reader.h.

Constructor & Destructor Documentation

◆ AdjListPropertyArrowChunkReader()

graphar::AdjListPropertyArrowChunkReader::AdjListPropertyArrowChunkReader	(	const std::shared_ptr< EdgeInfo > &	edge_info,
		const std::shared_ptr< PropertyGroup > &	property_group,
		AdjListType	adj_list_type,
		const std::string	prefix,
		const util::FilterOptions &	options = `{}`
	)

Initialize the AdjListPropertyArrowChunkReader.

Parameters

edge_info	The edge info that describes the edge type.
property_group	The property group that describes the property group.
adj_list_type	The adj list type for the edges.
prefix	The absolute prefix.

Definition at line 835 of file chunk_reader.cc.

Member Function Documentation

◆ Filter()

void graphar::AdjListPropertyArrowChunkReader::Filter ( util::Filter filter = nullptr )

Apply the row filter to the table. No parameter call Filter() will clear the filter.

Parameters

filter Predicate expression to filter rows.

Definition at line 1031 of file chunk_reader.cc.

◆ Make() [1/3]

Result< std::shared_ptr< AdjListPropertyArrowChunkReader > > graphar::AdjListPropertyArrowChunkReader::Make	(	const std::shared_ptr< EdgeInfo > &	edge_info,
		const std::shared_ptr< PropertyGroup > &	property_group,
		AdjListType	adj_list_type,
		const std::string &	prefix,
		const util::FilterOptions &	options = `{}`
	)

static

Create an AdjListPropertyArrowChunkReader instance from edge info.

Parameters

edge_info	The edge info that describes the edge type.
property_group	The property group that describes the property
adj_list_type	The adj list type for the edges.
prefix	The absolute prefix of the graph.
options	The filter options, default is empty.

Definition at line 1040 of file chunk_reader.cc.

◆ Make() [2/3]

Result< std::shared_ptr< AdjListPropertyArrowChunkReader > > graphar::AdjListPropertyArrowChunkReader::Make	(	const std::shared_ptr< GraphInfo > &	graph_info,
		const std::string &	src_type,
		const std::string &	edge_type,
		const std::string &	dst_type,
		const std::shared_ptr< PropertyGroup > &	property_group,
		AdjListType	adj_list_type,
		const util::FilterOptions &	options = `{}`
	)

static

Create an AdjListPropertyArrowChunkReader instance from graph info and property group.

Parameters

graph_info	The graph info that describes the graph.
src_type	The source vertex type.
edge_type	The edge type.
dst_type	The destination vertex type.
property_group	The property group that describes the property group.
adj_list_type	The adj list type for the edges.
options	The filter options, default is empty.

Definition at line 1055 of file chunk_reader.cc.

◆ Make() [3/3]

Result< std::shared_ptr< AdjListPropertyArrowChunkReader > > graphar::AdjListPropertyArrowChunkReader::Make	(	const std::shared_ptr< GraphInfo > &	graph_info,
		const std::string &	src_type,
		const std::string &	edge_type,
		const std::string &	dst_type,
		const std::string &	property_name,
		AdjListType	adj_list_type,
		const util::FilterOptions &	options = `{}`
	)

static

Create an AdjListPropertyArrowChunkReader instance from graph info and property name.

Parameters

graph_info	The graph info that describes the graph.
src_type	The source vertex type.
edge_type	The edge type.
dst_type	The destination vertex type.
property_name	The name of one property in the property group you want to read.
adj_list_type	The adj list type for the edges.
options	The filter options, default is empty.

Definition at line 1070 of file chunk_reader.cc.

◆ next_chunk()

Status graphar::AdjListPropertyArrowChunkReader::next_chunk ( )

Sets chunk position indicator to next chunk.

Returns: Status: ok or EndOfChunk error if the reader is at the end of current vertex chunk, or IndexError error if the reader is at the end of all vertex chunks.

Definition at line 992 of file chunk_reader.cc.

◆ seek()

Status graphar::AdjListPropertyArrowChunkReader::seek ( IdType offset )

Sets chunk position indicator for reader by edge index.

Parameters

offset edge index of the vertex chunk. Note: the offset is the edge index of the vertex chunk, not the edge index of the whole graph.

Definition at line 943 of file chunk_reader.cc.

◆ seek_chunk_index()

Status graphar::AdjListPropertyArrowChunkReader::seek_chunk_index	(	IdType	vertex_chunk_index,
		IdType	chunk_index = `0`
	)

Sets chunk position to the specific vertex chunk and edge chunk.

Parameters

vertex_chunk_index	the vertex chunk index.
chunk_index	the edge chunk index of vertex_chunk_index.

Returns: Status: ok or error

Definition at line 1016 of file chunk_reader.cc.

◆ seek_dst()

Status graphar::AdjListPropertyArrowChunkReader::seek_dst ( IdType id )

Sets chunk position indicator for reader by destination vertex id.

Parameters

id	the destination vertex id.

Definition at line 912 of file chunk_reader.cc.

◆ seek_src()

Status graphar::AdjListPropertyArrowChunkReader::seek_src ( IdType id )

Sets chunk position indicator for reader by source vertex id.

Parameters

id	the source vertex id.

Definition at line 880 of file chunk_reader.cc.

◆ Select()

void graphar::AdjListPropertyArrowChunkReader::Select ( util::ColumnNames column_names = std::nullopt )

Apply the projection to the table to be read. No parameter call Select() will clear the projection.

Parameters

column_names The name of columns to be selected.

Definition at line 1035 of file chunk_reader.cc.

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

src/graphar/arrow/chunk_reader.h
src/graphar/arrow/chunk_reader.cc

Public Types

Public Member Functions

Static Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ AdjListPropertyArrowChunkReader()

Member Function Documentation

◆ Filter()

◆ Make() [1/3]

◆ Make() [2/3]

◆ Make() [3/3]

◆ next_chunk()

◆ seek()

◆ seek_chunk_index()

◆ seek_dst()

◆ seek_src()

◆ Select()