gs::CSVTableRecordBatchSupplier Class Reference

#include <csv_fragment_loader.h>

Inheritance diagram for gs::CSVTableRecordBatchSupplier:

Collaboration diagram for gs::CSVTableRecordBatchSupplier:

Public Member Functions
	CSVTableRecordBatchSupplier (label_t label_id, const std::string &file_path, arrow::csv::ConvertOptions convert_options, arrow::csv::ReadOptions read_options, arrow::csv::ParseOptions parse_options)
std::shared_ptr< arrow::RecordBatch >	GetNextBatch () override
Public Member Functions inherited from gs::IRecordBatchSupplier
virtual	~IRecordBatchSupplier ()=default

Private Attributes
std::string	file_path_
std::shared_ptr< arrow::Table >	table_
std::shared_ptr< arrow::TableBatchReader >	reader_

Constructor & Destructor Documentation

CSVTableRecordBatchSupplier()

gs::CSVTableRecordBatchSupplier::CSVTableRecordBatchSupplier	(	label_t	label_id,
		const std::string &	file_path,
		arrow::csv::ConvertOptions	convert_options,
		arrow::csv::ReadOptions	read_options,
		arrow::csv::ParseOptions	parse_options
	)

Member Function Documentation

GetNextBatch()

std::shared_ptr< arrow::RecordBatch > gs::CSVTableRecordBatchSupplier::GetNextBatch ( )

overridevirtual

Implements gs::IRecordBatchSupplier.

Member Data Documentation

file_path_

std::string gs::CSVTableRecordBatchSupplier::file_path_

private

reader_

std::shared_ptr<arrow::TableBatchReader> gs::CSVTableRecordBatchSupplier::reader_

private

table_

std::shared_ptr<arrow::Table> gs::CSVTableRecordBatchSupplier::table_

private

---

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

• /home/runner/work/GraphScope/GraphScope/flex/storages/rt_mutable_graph/loader/csv_fragment_loader.h
• /home/runner/work/GraphScope/GraphScope/flex/storages/rt_mutable_graph/loader/csv_fragment_loader.cc