gs::ODPSTableRecordBatchSupplier Class Reference

#include <odps_fragment_loader.h>

Inheritance diagram for gs::ODPSTableRecordBatchSupplier:

Collaboration diagram for gs::ODPSTableRecordBatchSupplier:

Public Member Functions
	ODPSTableRecordBatchSupplier (label_t label_id, const std::string &file_path, const ODPSReadClient &odps_table_reader, const std::string &session_id, int split_count, TableIdentifier table_identifier, int thread_num)
std::shared_ptr< arrow::RecordBatch >	GetNextBatch () override
Public Member Functions inherited from gs::IRecordBatchSupplier
virtual	~IRecordBatchSupplier ()=default

Private Attributes
std::string	file_path_
const ODPSReadClient &	odps_read_client_
std::string	session_id_
TableIdentifier	table_identifier_
std::shared_ptr< arrow::Table >	table_
std::shared_ptr< arrow::TableBatchReader >	reader_

Constructor & Destructor Documentation

ODPSTableRecordBatchSupplier()

gs::ODPSTableRecordBatchSupplier::ODPSTableRecordBatchSupplier	(	label_t	label_id,
		const std::string &	file_path,
		const ODPSReadClient &	odps_table_reader,
		const std::string &	session_id,
		int	split_count,
		TableIdentifier	table_identifier,
		int	thread_num
	)

Member Function Documentation

GetNextBatch()

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

overridevirtual

Implements gs::IRecordBatchSupplier.

Member Data Documentation

file_path_

std::string gs::ODPSTableRecordBatchSupplier::file_path_

private

odps_read_client_

const ODPSReadClient& gs::ODPSTableRecordBatchSupplier::odps_read_client_

private

reader_

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

private

session_id_

std::string gs::ODPSTableRecordBatchSupplier::session_id_

private

table_

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

private

table_identifier_

TableIdentifier gs::ODPSTableRecordBatchSupplier::table_identifier_

private

---

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

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