gs::CSVStreamRecordBatchSupplier Class Reference

#include <csv_fragment_loader.h>

Inheritance diagram for gs::CSVStreamRecordBatchSupplier:

Collaboration diagram for gs::CSVStreamRecordBatchSupplier:

Public Member Functions
	CSVStreamRecordBatchSupplier (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::csv::StreamingReader >	reader_

Constructor & Destructor Documentation

CSVStreamRecordBatchSupplier()

gs::CSVStreamRecordBatchSupplier::CSVStreamRecordBatchSupplier	(	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::CSVStreamRecordBatchSupplier::GetNextBatch ( )

overridevirtual

Implements gs::IRecordBatchSupplier.

Member Data Documentation

file_path_

std::string gs::CSVStreamRecordBatchSupplier::file_path_

private

reader_

std::shared_ptr<arrow::csv::StreamingReader> gs::CSVStreamRecordBatchSupplier::reader_

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